Buenas,
Estoy trabajando con fiware y al realizar una subscriptions se esta enviando esta informacion a un método que que definido en mi API rest, y me gustaría guardar esa información en mi base de datos.
La información que me llega desde el ContextBroker es:
{
"subscriptionId" : "5a268a598dc68904bbc7b3cf",
"originator" : "localhost",
"contextResponses" : [
{
"contextElement" : {
"type" : "Temperatura",
"isPattern" : "false",
"id" : "S_Temp001",
"attributes" : [
{
"name" : "Tem_int",
"type" : "float",
"value" : 22,
"metadatas" : [
{
"name" : "accuracy",
"type" : "Float",
"value": 44 }
]
},
{
"name" : "Tem_out",
"type" : "Integer",
"value" : 22
}
]
},
"statusCode" : {
"code" : "200",
"reasonPhrase" : "OK"
}
}
]
}
El método que he definido en mi API es este:
//insertarBD
function postinsertbdarduino1(req, res) {
var inver = {
fiwareServicePath: String,
entityId: String,
entityType: String,
attrName: String,
attrType: String,
attrValue: String,
attrMd: String
};
var params = req.body;
//comprobamos si llega la pass && nombre etc y ciframos
//Asignar valores al objeto usuario
//inver.entityId = params.entityId;
inver.fiwareServicePath = params.fiwareServicePath;
inver.entityId = params.id;
inver.entityType = params.type;
inver.attrName = params.name;
inver.attrType = params.attrType;
inver.attrValue = params.attrValue;
inver.attrMd = params.attrMd;
pool.getConnection(function(err, connection){
if (err) {
console.log('Error al pedir una conexión: '+err);
return;
}
console.log("pruebas de conexion");
//si queremos añadir otras condiciones en el where seria poner los campos y ? y luego a que equivale
//'SELECT * FROM todos WHERE id=? AND username=?', [req.params.id, user.username], function(err, rows)
connection.query('INSERT INTO inver SET ?', [inver], function(err, rows) {
if(err)
{
throw err;
console.log('Error al Conectar' + error);
}
else
{
res.status(200).json(rows);
}
});
//para que pueda ser reutilizada por el pool, es importante "liberarla"
connection.release();
});
}
Por ahora solo le estoy pasando el id, el type y el name.
Pero me esta guardando el registro en la base de datos a vació.
¿Como puedo solucionar esto?
Gracias un saludo.
EDIT01:
Acabo de lanzar el JSON he cambiado en mi metodo de la API por el valor subscriptionId inver.entityId = params.subscriptionId;
y si me llega el dato, pero necesito recuperar los datos "type" : "Temperatura"
"id" : "S_Temp001",
{
"name" : "Tem_int",
"type" : "float",
"value" : 22,
"metadatas" : [
{
"name" : "accuracy",
"type" : "Float",
"value": 44 }
]
},
{
"name" : "Tem_out",
"type" : "Integer",
"value" : 22
}
Como puedo llegar hasta esa parte del JSON?
Gracias.