Firehose - 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.

Firehose

Tindakan Firehose (firehose) mengirimkan data dari pesan MQTT ke aliran Amazon Data Firehose.

Persyaratan

Tindakan aturan ini memiliki persyaratan sebagai berikut:

  • Peran IAM yang AWS IoT dapat diasumsikan untuk melakukan firehose:PutRecord operasi. Untuk informasi selengkapnya, lihat Memberikan AWS IoT aturan akses yang dibutuhkannya.

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

  • Jika Anda menggunakan Firehose untuk mengirim data ke bucket Amazon S3, dan Anda menggunakan pelanggan AWS KMS yang AWS KMS key berhasil mengenkripsi data saat istirahat di Amazon S3, Firehose harus memiliki akses ke bucket Anda dan izin untuk menggunakan atas nama pemanggil. AWS KMS key Untuk informasi selengkapnya, lihat Memberikan akses Firehose ke tujuan Amazon S3 di Panduan Pengembang Amazon Data Firehose.

Parameter

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

batchMode

(Opsional) Apakah akan mengirimkan aliran Firehose sebagai batch dengan menggunakan. PutRecordBatch Nilai default-nya adalah false.

batchModeKapan true dan pernyataan SQL aturan mengevaluasi ke Array, setiap elemen Array membentuk satu catatan dalam permintaan. PutRecordBatch Array yang dihasilkan tidak dapat memiliki lebih dari 500 record.

Mendukung template substitusi: Tidak

deliveryStreamName

Aliran Firehose untuk menulis data pesan.

Mendukung template substitusi: API dan hanya AWS CLI

separator

(Opsional) Pemisah karakter yang digunakan untuk memisahkan catatan yang ditulis ke aliran Firehose. Jika Anda menghilangkan parameter ini, aliran tidak menggunakan pemisah. Nilai yang valid: , (koma), \t (tab), \n (baris baru), \r\n (baris baru Windows).

Mendukung template substitusi: Tidak

roleArn

Peran IAM yang memungkinkan akses ke aliran Firehose. Untuk informasi selengkapnya, lihat Persyaratan.

Mendukung template substitusi: Tidak

Contoh

Contoh JSON berikut mendefinisikan tindakan Firehose dalam aturan. AWS IoT 

{
    "topicRulePayload": {
        "sql": "SELECT * FROM 'some/topic'", 
        "ruleDisabled": false, 
        "awsIotSqlVersion": "2016-03-23",
        "actions": [
            {
                "firehose": {
                    "deliveryStreamName": "my_firehose_stream",
                    "roleArn": "arn:aws:iam::123456789012:role/aws_iot_firehose"
                }
            }
        ] 
    }
}

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

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

Lihat juga