ストリームへきちんとレコードを送信できているか確認したくなった時のために、覚書程度にCLIの書き方を残しておきます
また初めてkinesis系を利用しましたが、下記のチュートリアルが非常にわかりやすかったです。
リアルタイムデータ処理を行うサーバーレスアプリケーションを構築する
AWS CLIを使って初めてAmazon Kinesisを使ってみたを参考にさせていただきました。
# aws kinesis list-streams
{
"StreamNames": [
"wildrydes",
"wildrydes-summary"
]
}
# aws kinesis describe-stream --stream-name wildrydes-summary
{
"StreamDescription": {
"KeyId": null,
"EncryptionType": "NONE",
"StreamStatus": "ACTIVE",
"StreamName": "wildrydes-summary",
"Shards": [
{
"ShardId": "shardId-000000000000",
"HashKeyRange": {
"EndingHashKey": "340282366920938463463374607431768211455",
"StartingHashKey": "0"
},
"SequenceNumberRange": {
"StartingSequenceNumber": "49598050274027636832164871047437518224631163117463666690"
}
}
],
"StreamARN": "arn:aws:kinesis:us-east-1:986846499074:stream/wildrydes-summary",
"EnhancedMonitoring": [
{
"ShardLevelMetrics": []
}
],
"StreamCreationTimestamp": 1564389896.0,
"RetentionPeriodHours": 24
}
}
# aws kinesis get-shard-iterator --shard-id shardId-000000000000 --shard-iterator-type TRIM_HORIZON --stream-name wildrydes-summary
{
"ShardIterator": "AAAAAAAAAAEgynDQ5e7GAzU5jCnxKWfiky7pZ2vuY7kV6AWLp6G23jZPsbCJNs118xC0rb20Jkjh+0uu23PAx7bq5yQVJc9Dv9Uwmmv6q17xDMPuiSdxBkloj6RpRuoO2UjCXb5nq0Uac2KHE7o+QKFv3FN4p60bUYg2AQ2yeVMAXyh2boF8aOyCqbL9ktzP6TB/LA1lzGRIUxtvgWx8fExRiPRlKffP"
}
aws kinesis get-records --shard-iterator AAAAAAAAAAHFu1JR4Gj7k6UgHJs1tZMWGRtwvgjGPolNk+Eh1GI72dXHKrtxUMD+lR21FII4MXB0JecCkarh3tewMAh+Tw/tPVfhnYoppSR8pyfzgtaWBGovVKwv12cli63Ixf3M1oiRuRQ0fFjJzfxumtXbPNVij67JntAjLt98j7AG6tC7PNOrME0cvkyN5Y2D5nNbbVFT6bkRr+pOOzm7nwT8NtB7OD/kfivMOz3DcbGGLccwaw== | jq '.Records[].Data' -r | base64 -d