網頁

2022/5/11

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


沒有留言:

張貼留言