Contoh Firehose menggunakan AWS CLI

Contoh kode berikut menunjukkan cara melakukan tindakan dan menerapkan skenario umum dengan menggunakan AWS Command Line Interface dengan Firehose.

Tindakan merupakan kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Sementara tindakan menunjukkan cara memanggil fungsi layanan individual, Anda dapat melihat tindakan dalam konteks dalam skenario terkait.

Setiap contoh menyertakan tautan ke kode sumber lengkap, di mana Anda dapat menemukan instruksi tentang cara mengatur dan menjalankan kode dalam konteks.

Tindakan

daftar pengiriman-aliran

Contoh kode berikut menunjukkan cara menggunakanlist-delivery-streams.

AWS CLI

Untuk membuat daftar aliran pengiriman yang tersedia

list-delivery-streamsContoh berikut mencantumkan aliran pengiriman yang tersedia di AWS akun Anda.

aws firehose list-delivery-streams

Output:

{
    "DeliveryStreamNames": [
        "my-stream"
    ],
    "HasMoreDeliveryStreams": false
}

Untuk informasi selengkapnya, lihat Membuat Aliran Pengiriman Amazon Kinesis Data Firehose di Panduan Developer Amazon Kinesis Data Firehose.

• Untuk detail API, lihat ListDeliveryStreams di Refer AWS CLI ensi Perintah.

put-rekaman-batch

Contoh kode berikut menunjukkan cara menggunakanput-record-batch.

AWS CLI

Untuk menulis beberapa rekaman ke aliran

put-record-batchContoh berikut menulis tiga rekaman ke aliran. Data dikodekan dalam format Base64.

aws firehose put-record-batch \
    --delivery-stream-name my-stream \
    --records file://records.json

Isi dari myfile.json:

[
    {"Data": "Rmlyc3QgdGhpbmc="},
    {"Data": "U2Vjb25kIHRoaW5n"},
    {"Data": "VGhpcmQgdGhpbmc="}
]

Output:

{
    "FailedPutCount": 0,
    "Encrypted": false,
    "RequestResponses": [
        {
            "RecordId": "9D2OJ6t2EqCTZTXwGzeSv/EVHxRoRCw89xd+o3+sXg8DhYOaWKPSmZy/CGlRVEys1u1xbeKh6VofEYKkoeiDrcjrxhQp9iF7sUW7pujiMEQ5LzlrzCkGosxQn+3boDnURDEaD42V7GiixpOyLJkYZcae1i7HzlCEoy9LJhMr8EjDSi4Om/9Vc2uhwwuAtGE0XKpxJ2WD7ZRWtAnYlKAnvgSPRgg7zOWL"
        },
        {
            "RecordId": "jFirejqxCLlK5xjH/UNmlMVcjktEN76I7916X9PaZ+PVaOSXDfU1WGOqEZhxq2js7xcZ552eoeDxsuTU1MSq9nZTbVfb6cQTIXnm/GsuF37Uhg67GKmR5z90l6XKJ+/+pDloFv7Hh9a3oUS6wYm3DcNRLTHHAimANp1PhkQvWpvLRfzbuCUkBphR2QVzhP9OiHLbzGwy8/DfH8sqWEUYASNJKS8GXP5s"
        },
        {
            "RecordId": "oy0amQ40o5Y2YV4vxzufdcMOOw6n3EPr3tpPJGoYVNKH4APPVqNcbUgefo1stEFRg4hTLrf2k6eliHu/9+YJ5R3iiedHkdsfkIqX0XTySSutvgFYTjNY1TSrK0pM2sWxpjqqnk3+2UX1MV5z88xGro3cQm/DTBt3qBlmTj7Xq8SKVbO1S7YvMTpWkMKA86f8JfmT8BMKoMb4XZS/sOkQLe+qh0sYKXWl"
        }
    ]
}

Untuk informasi selengkapnya, lihat Mengirim Data ke Aliran Pengiriman Firehose Data Amazon Kinesis di Panduan Pengembang Amazon Kinesis Data Firehose.

• Untuk detail API, lihat PutRecordBatch di Refer AWS CLI ensi Perintah.

put-record

Contoh kode berikut menunjukkan cara menggunakanput-record.

AWS CLI

Menulis rekaman ke stream

put-recordContoh berikut menulis data ke aliran. Data dikodekan dalam format Base64.

aws firehose put-record \
    --delivery-stream-name my-stream \
    --record '{"Data":"SGVsbG8gd29ybGQ="}'

Output:

{
    "RecordId": "RjB5K/nnoGFHqwTsZlNd/TTqvjE8V5dsyXZTQn2JXrdpMTOwssyEb6nfC8fwf1whhwnItt4mvrn+gsqeK5jB7QjuLg283+Ps4Sz/j1Xujv31iDhnPdaLw4BOyM9Amv7PcCuB2079RuM0NhoakbyUymlwY8yt20G8X2420wu1jlFafhci4erAt7QhDEvpwuK8N1uOQ1EuaKZWxQHDzcG6tk1E49IPeD9k",
    "Encrypted": false
}

Untuk informasi selengkapnya, lihat Mengirim Data ke Aliran Pengiriman Firehose Data Amazon Kinesis di Panduan Pengembang Amazon Kinesis Data Firehose.

• Untuk detail API, lihat PutRecord di Refer AWS CLI ensi Perintah.