2020-10-12 19:36:50 +01:00
|
|
|
# aws kinesis
|
|
|
|
|
|
2024-03-04 09:32:50 +00:00
|
|
|
> Interact with the Amazon Kinesis Data Streams, a service that scales elastically for real-time processing of streaming big data.
|
2020-10-12 19:36:50 +01:00
|
|
|
> More information: <https://docs.aws.amazon.com/cli/latest/reference/kinesis/index.html#cli-aws-kinesis>.
|
|
|
|
|
|
|
|
|
|
- Show all streams in the account:
|
|
|
|
|
|
|
|
|
|
`aws kinesis list-streams`
|
|
|
|
|
|
|
|
|
|
- Write one record to a Kinesis stream:
|
|
|
|
|
|
|
|
|
|
`aws kinesis put-record --stream-name {{name}} --partition-key {{key}} --data {{base64_encoded_message}}`
|
|
|
|
|
|
|
|
|
|
- Write a record to a Kinesis stream with inline base64 encoding:
|
|
|
|
|
|
|
|
|
|
`aws kinesis put-record --stream-name {{name}} --partition-key {{key}} --data "$( echo "{{my raw message}}" | base64 )"`
|
|
|
|
|
|
|
|
|
|
- List the shards available on a stream:
|
|
|
|
|
|
|
|
|
|
`aws kinesis list-shards --stream-name {{name}}`
|
|
|
|
|
|
|
|
|
|
- Get a shard iterator for reading from the oldest message in a stream's shard:
|
|
|
|
|
|
|
|
|
|
`aws kinesis get-shard-iterator --shard-iterator-type TRIM_HORIZON --stream-name {{name}} --shard-id {{id}}`
|
|
|
|
|
|
|
|
|
|
- Read records from a shard, using a shard iterator:
|
|
|
|
|
|
|
|
|
|
`aws kinesis get-records --shard-iterator {{iterator}}`
|
