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 poin dalam satu permintaan tulis. AWS IoT Core mengonversi 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 endpoint dengan mengautentikasi terhadap InfluxDB API menggunakan kredenal yang Anda berikan:

Respons yang berhasil (2xx) menetapkan status tujuan keENABLED. Pada kegagalan, AWS IoT Core atur status keERROR. Untuk mencoba kembali validasi, panggil UpdateTopicRuleDestination dengan status yang disetel ke. IN_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 batching

Perangkat IoT Anda mengumpulkan 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 satu permintaan tulis. Anda tidak perlu konfigurasi tambahan.

Server-side batching

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

Tindakan InfluxDB diukur berdasarkan ukuran muatan keluar dalam peningkatan 5 KiB. Line-protocol Kegagalan konversi juga diukur.

Per-element template untuk muatan array

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

Sintaks dari dua template substitusi

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

Contoh

Mengingat 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

Konten rekaman 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 mengubah 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 muatan ditulis ke satu tableName sebagai satu catatan. Message-scope template substitusi (${...}) didukung dalam tindakan kesalahan tableName dantags.

Output tindakan kesalahan

Ketika tindakan kesalahan dipicu, payload output 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 digunakan, dengan satu entri untuk setiap payloadsWithMetadata pesan MQTT masuk yang berbeda. Nilai setiap kegagalan mengacu pada affectedIds 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 backoff eksponensial. Untuk respons HTTP 401, AWS IoT Core muat ulang token dari AWS Secrets Manager dan coba ulang permintaan sekali. Non-retryable kesalahan (404, 422) segera memicu tindakan kesalahan. 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"
        }
      }
    ]
  }
}

Sampel muatan:

{
  "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 menurut abjad.

Client-batched muatan 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"
  }
}

Contoh muatan (dipublikasikan 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 batching 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 dapat batchConfig menyusun ulang poin dari muatan batch sisi klien. Rules Engine mengakumulasi poin dari beberapa pesan masuk ke dalam satu batch sisi server. Karena pesan tiba secara asinkron dari perangkat atau topik yang berbeda, poin yang diurutkan dalam muatan 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 mereka muncul dalam setiap muatan klien. Tiga titik dari Perangkat A (stempel waktu 1700000000000, 1700000000100, 1700000000200) disisipkan 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, sehingga penataan ulang tidak memengaruhi kebenaran kueri. Namun, jika aplikasi Anda bergantung pada semantik urutan tulis (misalnya, menangani konflik tipe bidang atau deduplikasi tulis-menang terakhir dalam milidetik yang sama), ketahuilah bahwa urutan penulisan efektif mungkin berbeda dari urutan publikasi.