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 MQTT pesan ke aliran Amazon Data Firehose.

Persyaratan

Tindakan aturan ini memiliki persyaratan sebagai berikut:

  • IAMPeran 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 SQL pernyataan aturan mengevaluasi ke Array, setiap elemen Array membentuk satu catatan dalam PutRecordBatch permintaan. 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

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

Mendukung template substitusi: Tidak

Contoh

JSONContoh berikut mendefinisikan tindakan Firehose dalam AWS IoT aturan.

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

JSONContoh 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