使用 的 Firehose 範例 AWS CLI - AWS SDK 程式碼範例

文件 AWS SDK AWS 範例 SDK 儲存庫中有更多可用的 GitHub 範例。

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

使用 的 Firehose 範例 AWS CLI

下列程式碼範例示範如何搭配 AWS Command Line Interface Firehose 使用 來執行動作和實作常見案例。

Actions 是大型程式的程式碼摘錄,必須在內容中執行。雖然 動作會示範如何呼叫個別服務函數,但您可以在其相關案例中查看內容中的動作。

每個範例都包含完整原始程式碼的連結,您可以在其中找到如何在內容中設定和執行程式碼的指示。

主題

動作

下列程式碼範例示範如何使用 list-delivery-streams

AWS CLI

列出可用的交付串流

下列list-delivery-streams範例列出您 AWS 帳戶中可用的交付串流。

aws firehose list-delivery-streams

輸出:

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

如需詳細資訊,請參閱《Amazon Kinesis Data Firehose 開發人員指南》中的建立 Amazon Kinesis Data Firehose 交付串流

下列程式碼範例示範如何使用 put-record-batch

AWS CLI

將多筆記錄寫入串流

下列put-record-batch範例會將三個記錄寫入串流。資料以 Base64 格式編碼。

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

myfile.json 的內容:

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

輸出:

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

如需詳細資訊,請參閱 Amazon Kinesis Data Firehose 開發人員指南中的將資料傳送至 Amazon Kinesis Data Firehose 交付串流Amazon Kinesis Data Firehose

  • 如需 API 詳細資訊,請參閱 AWS CLI 命令參考中的 PutRecordBatch

下列程式碼範例示範如何使用 put-record

AWS CLI

將記錄寫入串流

下列put-record範例會將資料寫入串流。資料以 Base64 格式編碼。

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

輸出:

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

如需詳細資訊,請參閱 Amazon Kinesis Data Firehose 開發人員指南中的將資料傳送至 Amazon Kinesis Data Firehose 交付串流Amazon Kinesis Data Firehose

  • 如需 API 詳細資訊,請參閱 AWS CLI 命令參考中的 PutRecord