View a markdown version of this page

Kinesis Data Streams - AWS IoT Core
PersyaratanParameterContohLihat juga

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

Kinesis Data Streams

Tindakan Kinesis Data Streams (kinesis) menulis data dari pesan MQTT ke Amazon Kinesis Data Streams.

Persyaratan

Tindakan aturan ini memiliki persyaratan sebagai berikut:

  • Peran IAM yang AWS IoT dapat diasumsikan untuk melakukan kinesis:PutRecord operasi. Untuk informasi selengkapnya, lihat Pemberian AWS IoT mengatur akses yang dibutuhkannya.

    Di AWS IoT konsol, Anda dapat memilih atau membuat peran AWS IoT untuk memungkinkan melakukan tindakan aturan ini.

  • Jika Anda menggunakan kunci yang AWS KMS dikelola pelanggan AWS KMS key (kunci KMS) untuk mengenkripsi data diam di Kinesis Data Streams, layanan harus memiliki izin untuk menggunakannya atas nama penelep AWS KMS key on. Untuk informasi selengkapnya, lihat Izin untuk menggunakan yang dibuat pengguna AWS KMS keys di Panduan Pengembang Amazon Kinesis Data Streams.

Parameter

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

stream

Aliran data Kinesis untuk menulis data.

Men dukung template substitusi: API dan AWS CLI hanya

partitionKey

Kunci partisi yang digunakan untuk menentukan ke mana pecahan data ditulis. Kunci partisi biasanya terdiri dari ekspresi (misalnya, ${topic()} atau${timestamp()}).

Mendukung template substitusi: Ya

roleArn

ARN dari peran IAM yang memberikan AWS IoT izin untuk mengakses aliran data Kinesis. Untuk informasi selengkapnya, lihat Persyaratan.

Mendukung template substitusi: Tidak

Contoh

Contoh JSON berikut mendefinisikan tindakan Kinesis Data Streams dalam AWS IoT aturan.

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'", 
        "ruleDisabled": false, 
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "kinesis": {
                    "streamName": "my_kinesis_stream", 
                    "partitionKey": "${topic()}",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis"
                }
            }
        ] 
    }
}

Contoh JSON berikut mendefinisikan tindakan Kinesis dengan template substitusi dalam AWS IoT aturan.

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'",
        "ruleDisabled": false,
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "kinesis": {
                    "streamName": "${topic()}",
                    "partitionKey": "${timestamp()}",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_kinesis"
                }
            }
        ]
    }
}

Lihat juga