View a markdown version of this page

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 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 Firehose untuk mengirim data ke bucket Amazon S3, dan Anda menggunakan AWS KMS pelanggan yang AWS KMS key berhasil mengenkripsi data saat diam di Amazon S3, Firehose harus memiliki akses ke bucket Anda dan izin untuk menggunakannya AWS KMS key atas nama penelepon. 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 dievaluasi ke Array, setiap elemen Array membentuk satu catatan dalam PutRecordBatch permintaan. Array yang dihasilkan tidak dapat memiliki lebih dari 500 catatan.

Mendukung template substitusi: Tidak

deliveryStreamName

Aliran Firehose untuk menulis data pesan.

Men dukung template substitusi: API dan AWS CLI hanya

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

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

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