使用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"
}
沒有留言:
張貼留言