Skip to main content
2 de 5
Avances en el codigo
Manolait
  • 521
  • 1
  • 10
  • 19

Parsear llamada Post JavaScript NodeJS

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.

Manolait
  • 521
  • 1
  • 10
  • 19