Configure el flujo de retención de datos

El flujo de retención de datos se puede utilizar para mantener la visibilidad operativa en la periferia. Esto resulta útil durante las interrupciones de la red o cuando se necesita acceso inmediato a los datos. Este flujo se suscribe al intermediario MQTT para recibir los datos del dispositivo, los convierte al formato InfluxDB® y los almacena localmente. Al implementar este flujo, se crea un almacén de datos local resiliente al que los operadores pueden acceder sin depender de la nube, lo que permite la supervisión en tiempo real y la toma de decisiones en la periferia.

El flujo consta de tres componentes clave que trabajan juntos para garantizar que sus datos se capturen y almacenen correctamente:

• Cliente de suscripción MQTT: recibe los datos del intermediario, lo que garantiza la captura de todos los datos industriales relevantes

• Traductor InfluxDB: convierte la AWS IoT SiteWise carga útil al formato InfluxDB y prepara los datos para un almacenamiento eficiente de series temporales

• Escritor InfluxDB: gestiona el almacenamiento local, lo que garantiza la persistencia de los datos y la disponibilidad de las aplicaciones locales

Configure el cliente de suscripción MQTT

• Configure el cliente de suscripción MQTT en Node-RED para recibir datos del broker EMQX de MQTT importando el siguiente ejemplo. AWS IoT SiteWise

  ejemplo : MQTT en el nodo

  [
      {
          "id": "string",
          "type": "mqtt in",
          "z": "string",
          "name": "Subscribe to MQTT broker",
          "topic": "/Renton/WindFarm/Turbine/WindSpeed",
          "qos": "1",
          "datatype": "auto-detect",
          "broker": "string",
          "nl": false,
          "rap": true,
          "rh": 0,
          "inputs": 0,
          "x": 290,
          "y": 340,
          "wires": [
              [
                  "string"
              ]
          ]
      },
      {
          "id": "string",
          "type": "mqtt-broker",
          "name": "emqx",
          "broker": "127.0.0.1",
          "port": "1883",
          "clientid": "",
          "autoConnect": true,
          "usetls": false,
          "protocolVersion": "5",
          "keepalive": 15,
          "cleansession": true,
          "autoUnsubscribe": true,
          "birthTopic": "",
          "birthQos": "0",
          "birthPayload": "",
          "birthMsg": {},
          "closeTopic": "",
          "closePayload": "",
          "closeMsg": {},
          "willTopic": "",
          "willQos": "0",
          "willPayload": "",
          "willMsg": {},
          "userProps": "",
          "sessionExpiry": ""
      }
  ]

Esta suscripción garantiza que todos los datos relevantes publicados en el corredor se recopilen para su almacenamiento local, lo que proporciona un registro completo de sus operaciones industriales. El nodo utiliza los mismos parámetros de conexión MQTT que la Configure el editor MQTT sección, con los siguientes ajustes de suscripción:

• Tema — /Renton/WindFarm/Turbine/WindSpeed

• QoS — 1

Para obtener más información, consulte Conectarse a un broker de MQTT en la Node-REDdocumentación.

Configure el traductor InfluxDB

InfluxDB organiza los datos mediante etiquetas para la indexación y campos para los valores. Esta organización optimiza el rendimiento de las consultas y la eficiencia del almacenamiento de los datos de series temporales. Importe el nodo de función de ejemplo que contiene el JavaScript código para convertir la AWS IoT SiteWise carga útil al formato InfluxDB. El traductor divide las propiedades en dos grupos:

• Etiquetas: propiedades de calidad y nombre para una indexación eficiente

• Campos: marca de tiempo (en milisegundos desde la época) y valor

ejemplo : Nodo de función de traducción a una carga útil de InfluxDB

[
    {
        "id": "string",
        "type": "function",
        "z": "string",
        "name": "Translate to InfluxDB payload",
        "func": "let data = msg.payload;\n\nlet timeInSeconds = data.propertyValues[0].timestamp.timeInSeconds;\nlet offsetInNanos = data.propertyValues[0].timestamp.offsetInNanos;\nlet timestampInMilliseconds = (timeInSeconds * 1000) + (offsetInNanos / 1000000);\n\nmsg.payload = [\n    {\n        \"timestamp(milliseconds_since_epoch)\": timestampInMilliseconds,\n        \"value\": data.propertyValues[0].value.doubleValue\n    },\n    {\n        \"name\": data.propertyAlias,\n        \"quality\": data.propertyValues[0].quality\n    }\n]\n\nreturn msg",
        "outputs": 1,
        "timeout": "",
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 560,
        "y": 340,
        "wires": [
            [
                "string"
            ]
        ]
    }
]

Para ver opciones de configuración adicionales, consulte el node-red-contrib-influxdbrepositorio de Node-RED. GitHub

Configure el escritor InfluxDB

El nodo de escritura de InfluxDB es el componente final de su flujo de retención de datos, responsable de almacenar sus datos industriales en la base de datos local de InfluxDB. Este almacenamiento local es importante para mantener la visibilidad operativa durante las interrupciones de la red y proporcionar acceso inmediato a los datos para las aplicaciones en las que el tiempo es crucial.

1. Instale el node-red-contrib-influxdb paquete mediante la opción Administrar paleta. Este paquete proporciona los nodos necesarios para conectar Node-RED con InfluxDB.

2. Agregue un nodo de salida de InfluxDB a su flujo. Este nodo se encargará de la escritura real de los datos en su base de datos de InfluxDB.

3. Configure las propiedades del servidor para establecer una conexión segura con su instancia de InfluxDB:

   1. Establezca la versión en 2.0: esto especifica que se está conectando a InfluxDB v2.x, que usa una API diferente a la de las versiones anteriores

   2. Establece la URL enhttp://127.0.0.1:8086: esto apunta a tu instancia local de InfluxDB

   3. Introduzca su token de autenticación de InfluxDB. Este token seguro autoriza la conexión a su base de datos. Generó el token durante el Configure el almacenamiento local con InfluxDB procedimiento.

4. Especifique los parámetros de la ubicación de almacenamiento para definir dónde y cómo se almacenarán los datos:

   1. Introduzca el nombre de su organización de InfluxDB: la organización es un espacio de trabajo para un grupo de usuarios, al que pertenecen sus grupos y paneles. Para obtener más información, consulte Administrar organizaciones en. InfluxData Documentation

   2. Especifique el depósito de InfluxDB (por ejemplo,WindFarmData): el depósito equivale a una base de datos en los sistemas tradicionales y sirve como contenedor para los datos de sus series temporales

   3. Establezca la medición de InfluxDB (por ejemplo,TurbineData): la medición es similar a una tabla en las bases de datos relacionales y organiza los puntos de datos relacionados

nota

Busca el nombre de tu organización en la barra lateral izquierda de la instancia de InfluxDB. Los conceptos de organización, grupo y medición son fundamentales para el modelo de organización de datos de InfluxDB. Para obtener más información, consulte la documentación de InfluxDB.

Implemente y verifique el flujo de retención

Tras configurar todos los componentes del flujo de retención de datos, debe implementar y comprobar que el sistema funciona correctamente. Esta verificación garantiza que sus datos industriales se almacenen adecuadamente a nivel local para su acceso y análisis inmediatos.

1. Conecte los tres nodos como se muestra en el diagrama de flujo de retención de datos. Esto crea un proceso completo desde la suscripción de datos hasta el almacenamiento local.

   

2. Elija Deploy para aplicar los cambios y activar el flujo. Esto inicia el proceso de recopilación y almacenamiento de datos.

3. Utilice el explorador de datos de InfluxDB para consultar y visualizar sus datos. Esta herramienta le permite verificar que los datos se almacenan correctamente y crear visualizaciones iniciales de los datos de sus series temporales.

   En el explorador de datos, debería poder ver cómo se registran las mediciones de la velocidad del viento a lo largo del tiempo, lo que confirma que todo el proceso, desde la generación de datos hasta el almacenamiento local, funciona correctamente.

   Para obtener más información, consulte Consulta en el explorador de datos en el InfluxData Documentation.

Con el flujo de publicación de datos y el flujo de retención de datos implementados, ahora tiene un sistema completo que envía los datos a la AWS IoT SiteWise nube y, al mismo tiempo, mantiene una copia local para un acceso inmediato y una mayor resiliencia. Este enfoque de doble vía garantiza que obtenga los beneficios del análisis y el almacenamiento basados en la nube y, al mismo tiempo, mantenga la visibilidad operativa en la periferia.