Konfigurasikan aliran retensi data

Aliran retensi data dapat digunakan untuk menjaga visibilitas operasional di tepi. Ini berguna selama gangguan jaringan atau ketika Anda membutuhkan akses langsung ke data Anda. Alur ini berlangganan broker MQTT untuk menerima data perangkat, mengubahnya menjadi format InfluxDB®, dan menyimpannya secara lokal. Dengan menerapkan alur ini, Anda membuat penyimpanan data lokal yang tangguh yang dapat diakses operator tanpa dependensi cloud, memungkinkan pemantauan waktu nyata dan pengambilan keputusan di tepi.

Alur terdiri dari tiga komponen utama yang bekerja sama untuk memastikan data Anda ditangkap dan disimpan dengan benar:

• Klien berlangganan MQTT - Menerima data dari broker, memastikan Anda menangkap semua data industri yang relevan

• Penerjemah InfluxDB - Mengonversi AWS IoT SiteWise payload ke format InfluxDB, menyiapkan data untuk penyimpanan deret waktu yang efisien

• Penulis InfluxDB - Menangani penyimpanan lokal, memastikan persistensi data dan ketersediaan untuk aplikasi lokal

Siapkan klien berlangganan MQTT

• Konfigurasikan klien berlangganan MQTT di Node-Red untuk menerima data dari broker MQTT EMQX dengan mengimpor contoh di bawah ini. AWS IoT SiteWise

  contoh : MQTT di simpul

  [
      {
          "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": ""
      }
  ]

Langganan ini memastikan bahwa semua data relevan yang dipublikasikan ke broker ditangkap untuk penyimpanan lokal, memberikan catatan lengkap operasi industri Anda. Node menggunakan parameter koneksi MQTT yang sama dengan Konfigurasikan penerbit MQTT bagian, dengan pengaturan langganan berikut:

• Topik — /Renton/WindFarm/Turbine/WindSpeed

• QoS — 1

Untuk informasi selengkapnya, lihat Connect to an MQTT Broker di Dokumentasi. Node-RED

Konfigurasikan penerjemah InfluxDB

InfluxDB mengatur data menggunakan tag untuk pengindeksan dan bidang untuk nilai. Organisasi ini mengoptimalkan kinerja kueri dan efisiensi penyimpanan untuk data deret waktu. Impor node fungsi contoh yang berisi JavaScript kode untuk mengonversi AWS IoT SiteWise payload ke format InfluxDB. Penerjemah membagi properti menjadi dua kelompok:

• Tag - Kualitas dan properti nama untuk pengindeksan yang efisien

• Bidang - Timestamp (dalam milidetik sejak zaman) dan nilai

contoh : Fungsi simpul menerjemahkan ke muatan 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"
            ]
        ]
    }
]

Untuk opsi konfigurasi tambahan, lihat node-red-contrib-influxdbdi repositori Node-Red GitHub .

Siapkan penulis InfluxDB

Node penulis InfluxDB adalah komponen terakhir dalam aliran retensi data Anda, yang bertanggung jawab untuk menyimpan data industri Anda di database InfluxDB lokal. Penyimpanan lokal ini penting untuk menjaga visibilitas operasional selama gangguan jaringan dan menyediakan akses langsung ke data untuk aplikasi kritis waktu.

1. Instal node-red-contrib-influxdb paket melalui opsi Kelola palet. Paket ini menyediakan node yang diperlukan untuk menghubungkan Node-Red dengan InfluxDB.

2. Tambahkan node keluar InfluxDB ke alur Anda. Node ini akan menangani penulisan data aktual ke database InfluxDB Anda.

3. Konfigurasikan properti server untuk membuat koneksi aman ke instans InfluxDB Anda:

   1. Set Version to 2.0 - Ini menentukan bahwa Anda terhubung ke InfluxDB v2.x, yang menggunakan API yang berbeda dari versi sebelumnya

   2. Setel URL ke http://127.0.0.1:8086 - Ini menunjuk ke instans InfluxDB lokal Anda

   3. Masukkan token otentikasi InfluxDB Anda. Token aman ini mengotorisasi koneksi ke database Anda. Anda membuat token selama Siapkan penyimpanan lokal dengan InfluxDB prosedur.

4. Tentukan parameter lokasi penyimpanan untuk menentukan di mana dan bagaimana data Anda akan disimpan:

   1. Masukkan nama Organisasi InfluxDB Anda — Organisasi adalah ruang kerja untuk sekelompok pengguna, tempat bucket dan dasbor Anda berada. Untuk informasi selengkapnya, lihat Mengelola organisasi di InfluxData Documentation.

   2. Tentukan Bucket InfluxDB (misalnya,WindFarmData) - Bucket setara dengan database dalam sistem tradisional, berfungsi sebagai wadah untuk data deret waktu Anda

   3. Mengatur Pengukuran InfluxDB (misalnya,TurbineData) - Pengukurannya mirip dengan tabel dalam database relasional, mengatur titik data terkait

catatan

Temukan nama organisasi Anda di sidebar kiri instans InfluxDB. Konsep organisasi, bucket, dan pengukuran sangat penting untuk model organisasi data InfluxDB. Untuk informasi selengkapnya, lihat dokumentasi InfluxDB.

Menyebarkan dan memverifikasi aliran retensi

Setelah mengonfigurasi semua komponen aliran retensi data, Anda perlu menerapkan dan memverifikasi bahwa sistem berfungsi dengan benar. Verifikasi ini memastikan bahwa data industri Anda disimpan dengan benar secara lokal untuk akses dan analisis segera.

1. Hubungkan ketiga node seperti yang ditunjukkan pada diagram alir retensi data. Ini menciptakan pipeline lengkap dari langganan data ke penyimpanan lokal.

   

2. Pilih Deploy untuk menerapkan perubahan Anda dan mengaktifkan alur. Ini memulai proses pengumpulan dan penyimpanan data.

3. Gunakan InfluxDB Data Explorer untuk menanyakan dan memvisualisasikan data Anda. Alat ini memungkinkan Anda untuk memverifikasi bahwa data disimpan dengan benar dan untuk membuat visualisasi awal data deret waktu Anda.

   Di Data Explorer, Anda harus dapat melihat pengukuran kecepatan angin Anda direkam dari waktu ke waktu, mengonfirmasi bahwa seluruh pipa dari pembuatan data ke penyimpanan lokal berfungsi dengan benar.

   Untuk informasi selengkapnya, lihat Kueri di Penjelajah Data di InfluxData Documentation.

Dengan aliran publikasi data dan aliran retensi data yang diterapkan, Anda sekarang memiliki sistem lengkap yang mengirimkan data ke AWS IoT SiteWise cloud sambil mempertahankan salinan lokal untuk akses dan ketahanan langsung. Pendekatan jalur ganda ini memastikan bahwa Anda mendapatkan manfaat dari analitik dan penyimpanan berbasis cloud sambil mempertahankan visibilitas operasional di edge.