AWS CLI 發送資料到Kinesis Data Stream

使用AWS CLI發送資料到kinesis data stream。

範例環境：

• macOS
• AWS CLI 2(aws-cli/2.2.44)

事前要求

參考「AWS 建立IAM管理使用者及credentials」。

參考「AWS console 建立Kinesis Data Stream範例」建立一個名稱為KinesisDataStreamDemo的kinesis data stream。

發送資料

在AWS CLI輸入aws kinesis put-record --stream-name <stream-name> --data <-data> --partition-key <partition-key>發送資料到kinesis data stream。

• <stream-name> - Stream名稱，範例為KinesisDataStreamDemo。
• <data> - 上傳的資料，必須以Base64編碼，範例為"hello world"的Base64編碼aGVsbG8gd29ybGQK。
• <partition-key> - 用來決定資料要放在哪個shard。範例為demo-001。

所以輸入aws kinesis put-record --stream-name KinesisDataStreamDemo --data aGVsbG8gd29ybGQK --partition-key demo-001將資料"hello world"的base64編碼發送到KinesisDataStreamDemo的partition demo-001。執行後可得到上傳後的序號及shard id。

$ aws kinesis put-record --stream-name KinesisDataStreamDemo --data aGVsbG8gd29ybGQK  --partition-key demo-001
{
    "ShardId": "shardId-000000000000",
    "SequenceNumber": "49629408056911650938108365663704838332211167115079581698"
}

• Perform Basic Kinesis Data Stream Operations Using the AWS CLI