Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

InfluxDB

Pilih tindakan ini saat Anda ingin menanyakan telemetri perangkat untuk tren operasional atau memantau data deret waktu secara real time. Anda dapat menggunakan batching sisi klien atau sisi server untuk menggabungkan beberapa titik dalam satu permintaan tulis. AWS IoT Core mengkonversi setiap pesan ke protokol baris InfluxDB dan menulisnya ke database dan tabel yang ditentukan. Untuk informasi selengkapnya tentang format, lihat protokol baris InfluxDB dalam dokumentasi InfluxData . Untuk informasi tentang cluster terkelola, lihat Amazon Timestream untuk InfluxDB.

Prasyarat

Tindakan aturan ini memiliki prasyarat berikut:

Tujuan tindakan InfluxDB

Sebelum Anda dapat menggunakan tindakan aturan InfluxDB, Anda harus membuat tujuan tindakan InfluxDB. Tujuan menentukan parameter koneksi untuk instans InfluxDB Anda. AWS IoT Core kemudian memvalidasi kepemilikan titik akhir.

Membuat tujuan

Gunakan CreateTopicRuleDestination API untuk membuat tujuan InfluxDB:

{
  "destinationConfiguration": {
    "influxDBConfiguration": {
      "endpoint": "https://my-instance.timestream-influxdb.us-west-2.amazonaws.com:8086",
      "influxDBVersion": "V2",
      "secretId": "arn:aws:secretsmanager:us-west-2:111122223333:secret:my-influxdb-credentials-AbCdEf"
    }
  }
}

Parameter tujuan

Validasi kepemilikan titik akhir

Saat Anda membuat tujuan tindakan InfluxDB, AWS IoT Core memvalidasi kepemilikan titik akhir dengan mengautentikasi terhadap API InfluxDB menggunakan kredenSIAL yang Anda berikan:

Respons yang berhasil (2xx) menetapkan status tujuan keENABLED. Jika gagal, AWS IoT Core atur status keERROR. Untuk mencoba kembali validasi, panggil UpdateTopicRuleDestination dengan status disetel keIN_PROGRESS.

Pemetaan terminologi InfluxDB

Istilah berikut berbeda antara InfluxDB V2 dan V3.

Parameter

Saat Anda membuat AWS IoT aturan dengan tindakan InfluxDB, Anda harus menentukan informasi berikut:

Batching

Tindakan InfluxDB mendukung dua mode batching.

Client-side menggumpal

Perangkat IoT Anda menggabungkan data deret waktu sebagai array JSON dan menerbitkannya sebagai pesan MQTT tunggal. Dengan batching sisi klien, setiap elemen array menjadi satu titik protokol baris dalam permintaan tulis tunggal. Anda tidak memerlukan konfigurasi tambahan.

Server-side menggumpal

Gunakan batching sisi server untuk mengelompokkan pesan individual sebelum menulisnya ke InfluxDB. Konfigurasikan batching sisi server menggunakan parameter. batchConfig Batch disiram ketika batas (maxBatchSize,maxBatchOpenMs, ataumaxBatchSizeBytes) yang dikonfigurasi tercapai terlebih dahulu.

Tindakan InfluxDB diukur berdasarkan ukuran payload keluar dengan penambahan 5 KiB. Line-protocol Kegagalan konversi juga diukur.

Per-element template untuk muatan array

Saat perangkat IoT Anda mengirim data deret waktu berkelompok sebagai larik JSON, Anda dapat menggunakan “templat substitusi per-elemen” untuk menyelesaikan nilai dari setiap elemen array individu. Ini merutekan setiap titik data ke tabel yang berbeda atau menerapkan tag khusus elemen. Untuk informasi selengkapnya, lihat Per-element template.

Sintaks dua templat substitusi

Gunakan nilai @{...} in tableName dan tag untuk menyelesaikan ekspresi terhadap setiap elemen array secara individual.

Contoh

Diberikan payload perangkat berikut (array JSON):

[
  {"measurement_type": "temperature", "room": "kitchen", "timestamp": 1700000000000, "value": 23.5},
  {"measurement_type": "humidity", "room": "bedroom", "timestamp": 1700000001000, "value": 60.1}
]

Dan konfigurasi tindakan berikut:

{
  "influxDB": {
    "destinationArn": "arn:aws:iot:us-west-2:111122223333:ruledestination/influxdb/abc123",
    "roleArn": "arn:aws:iam::111122223333:role/iot-influxdb-role",
    "databaseName": "sensor_data",
    "tableName": "@{measurement_type}",
    "tags": {
      "room": "@{room}"
    },
    "timestampUnit": "ms"
  }
}

Output line-protocol yang dihasilkan berisi dua poin:

temperature,room=kitchen value=23.5 1700000000000
humidity,room=bedroom value=60.1 1700000001000

Pembatasan

Rekaman konten InfluxDB

Untuk setiap catatan dalam hasil kueri pasca-SQL, titik protokol baris InfluxDB yang dihasilkan berisi komponen-komponen ini:

Konversi jenis data

AWS IoT Core mengkonversi nilai JSON ke jenis protokol baris InfluxDB sebagai berikut:

Pembatasan penamaan

Kunci yang dipesan

Kunci payload berikut dilucuti dari bidang yang ditetapkan selama konversi protokol baris:

Tindakan kesalahan

Jika tindakan InfluxDB gagal, tindakan kesalahan yang dikonfigurasi dipicu.

Menggunakan InfluxDB sebagai tindakan kesalahan

Anda dapat mengonfigurasi tindakan InfluxDB sebagai tindakan kesalahan untuk aturan apa pun. Seluruh payload ditulis ke satu catatan tableName sebagai satu catatan. Message-scope template substitusi (${...}) didukung dalam tindakan kesalahan tableName dantags.

Keluaran tindakan kesalahan

Ketika tindakan kesalahan dipicu, muatan keluaran berisi:ruleName,,topic,cloudwatchTraceId, clientIdsourceIp, base64OriginalPayload (pesan Base64-encoded asli), dan failures array di mana setiap entri memilikifailedAction,failedResource, danerrorMessage.

Dengan batching sisi server, payload menggunakanpayloadsWithMetadata, dengan satu entri untuk setiap pesan MQTT masuk yang berbeda. Setiap affectedIds nilai kegagalan mengacu pada id nilai entri pesan tersebut; mereka bukan indeks titik. Array JSON sisi klien adalah satu pesan masuk meskipun menghasilkan beberapa titik InfluxDB. Untuk format payload lengkap, lihatTindakan Kesalahan untuk Batching.

Kesalahan yang dapat dicoba ulang (503) dicoba ulang dengan mundur eksponensial. Untuk respon HTTP 401, AWS IoT Core muat ulang token dari AWS Secrets Manager dan coba lagi permintaan sekali. Non-retryable kesalahan (404, 422) memicu tindakan kesalahan segera. Untuk batas coba lagi, lihat kuota AWS IoT Core layanan.

Contoh

Tindakan aturan InfluxDB

{
  "topicRulePayload": {
    "sql": "SELECT * FROM 'devices/+/telemetry'",
    "ruleDisabled": false,
    "awsIotSqlVersion": "2016-03-23",
    "actions": [
      {
        "influxDB": {
          "destinationArn": "arn:aws:iot:us-west-2:111122223333:ruledestination/influxdb/a1b2c3d4",
          "roleArn": "arn:aws:iam::111122223333:role/iot-influxdb-role",
          "organization": "my-org",
          "databaseName": "sensor_data",
          "tableName": "device_metrics",
          "tags": {
            "device_id": "${clientid()}",
            "location": "building-a"
          },
          "timestampUnit": "ms"
        }
      }
    ]
  }
}

Muatan sampel:

{
  "timestamp": 1700000000000,
  "temperature": 23.5,
  "humidity": 60.1,
  "pressure": 1013.25,
  "battery_level": 87
}

Protokol baris yang dihasilkan:

device_metrics,device_id=myDevice123,location=building-a temperature=23.5,humidity=60.1,pressure=1013.25,battery_level=87i 1700000000000

Urutan bidang dalam output dapat bervariasi - bidang tidak diurutkan berdasarkan abjad.

Client-batched payload array dengan templat per elemen

{
  "influxDB": {
    "destinationArn": "arn:aws:iot:us-west-2:111122223333:ruledestination/influxdb/a1b2c3d4",
    "roleArn": "arn:aws:iam::111122223333:role/iot-influxdb-role",
    "organization": "my-org",
    "databaseName": "sensor_data",
    "tableName": "@{measurement_type}",
    "tags": {
      "sensor_id": "@{sensor_id}",
      "location": "${topic(2)}"
    },
    "timestampUnit": "ns"
  }
}

Muatan sampel (diterbitkan kedevices/floor3/telemetry):

[
  {"measurement_type": "temperature", "sensor_id": "sensor-42", "timestamp": 1700000000000000000, "value": 23.5},
  {"measurement_type": "humidity", "sensor_id": "sensor-42", "timestamp": 1700000001000000000, "value": 60.1},
  {"measurement_type": "pressure", "sensor_id": "sensor-43", "timestamp": 1700000002000000000, "value": 1013.25}
]

Protokol baris yang dihasilkan:

temperature,location=floor3,sensor_id=sensor-42 value=23.5 1700000000000000000
humidity,location=floor3,sensor_id=sensor-42 value=60.1 1700000001000000000
pressure,location=floor3,sensor_id=sensor-43 value=1013.25 1700000002000000000

Server-side batch dengan InfluxDB

Untuk menambahkan batching sisi server ke tindakan InfluxDB apa pun, sertakan dalam konfigurasi tindakan: batchConfig

"batchConfig": {
  "maxBatchSize": 50,
  "maxBatchOpenMs": 1000,
  "maxBatchSizeBytes": 65536,
  "batchAcrossTopics": false
}

Kebijakan IAM untuk peran tindakan aturan

Kebijakan kepercayaan:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Principal": {"Service": "iot.amazonaws.com"},
      "Action": "sts:AssumeRole"
    }
  ]
}

Kebijakan izin:

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Effect": "Allow",
      "Action": "secretsmanager:GetSecretValue",
      "Resource": "arn:aws:secretsmanager:us-west-2:111122223333:secret:my-influxdb-secret-a1b2c3"
    }
  ]
}

Gabungan batching sisi klien dan sisi server (penataan ulang titik)

Saat Anda mengaktifkan batching sisi klien (muatan array JSON) dan batching sisi server (), ketahuilah bahwa batch sisi server batchConfig dapat menyusun ulang poin dari payload batched sisi klien. Mesin Aturan mengakumulasi poin dari beberapa pesan masuk ke dalam satu batch sisi server. Karena pesan datang secara asinkron dari perangkat atau topik yang berbeda, poin yang diurutkan dalam payload klien asli dapat disisipkan dengan poin dari pesan lain dalam penulisan akhir.

Konfigurasi tindakan:

{
  "influxDB": {
    "destinationArn": "arn:aws:iot:us-west-2:111122223333:ruledestination/influxdb/abc123",
    "roleArn": "arn:aws:iam::111122223333:role/iot-influxdb-role",
    "databaseName": "sensor_data",
    "tableName": "@{measurement_type}",
    "tags": {
      "device_id": "${topic(2)}",
      "floor": "@{floor}"
    },
    "timestampUnit": "ms",
    "batchConfig": {
      "maxBatchSize": 100,
      "maxBatchOpenMs": 500,
      "maxBatchSizeBytes": 65536,
      "batchAcrossTopics": true
    }
  }
}

Perangkat A menerbitkan devices/deviceA/telemetry pada waktu T:

[
  {"measurement_type": "temperature", "floor": "1", "timestamp": 1700000000000, "value": 22.1},
  {"measurement_type": "temperature", "floor": "2", "timestamp": 1700000000100, "value": 23.4},
  {"measurement_type": "humidity", "floor": "1", "timestamp": 1700000000200, "value": 55.0}
]

Perangkat B menerbitkan devices/deviceB/telemetry pada waktu T+10ms:

[
  {"measurement_type": "temperature", "floor": "3", "timestamp": 1700000000050, "value": 21.8},
  {"measurement_type": "humidity", "floor": "3", "timestamp": 1700000000150, "value": 62.3}
]

Kedua pesan tiba dalam jendela batch 500ms (maxBatchOpenMs), sehingga Rules Engine menggabungkan kelima poin menjadi satu batch sisi server.

Protokol baris yang dihasilkan (penulisan batch sisi server):

temperature,device_id=deviceB,floor=3 value=21.8 1700000000050
temperature,device_id=deviceA,floor=1 value=22.1 1700000000000
temperature,device_id=deviceA,floor=2 value=23.4 1700000000100
humidity,device_id=deviceB,floor=3 value=62.3 1700000000150
humidity,device_id=deviceA,floor=1 value=55.0 1700000000200

Perhatikan bahwa poin tidak lagi dalam urutan yang muncul dalam setiap payload klien. Tiga titik dari Perangkat A (stempel waktu 1700000000000, 1700000000100, 1700000000200) diselingi dengan dua titik dari Perangkat B (stempel waktu 1700000000050, 1700000000150). Batch sisi server tidak menjamin pemesanan asli dalam setiap pesan. InfluxDB menggunakan bidang stempel waktu untuk menempatkan setiap titik pada timeline, jadi penataan ulang tidak mempengaruhi kebenaran kueri. Namun, jika aplikasi Anda bergantung pada semantik urutan tulis (misalnya, menangani konflik jenis bidang atau deduplikasi last-write-wins dalam milidetik yang sama), ketahuilah bahwa urutan penulisan yang efektif mungkin berbeda dari urutan publikasi.