HiveBrain v1.2.0
Get Started
← Back to all entries
snippetbashTip

aws kinesis — Interact with the Amazon Kinesis Data Streams, a service that scales elastically for real-time proce

Submitted by: @import:tldr-pages··
0
Viewed 0 times
thecommandkinesisaws kinesisinteractcliamazonwith

Problem

How to use the aws kinesis command: Interact with the Amazon Kinesis Data Streams, a service that scales elastically for real-time processing of streaming big data. More information: <https://docs.aws.amazon.com/cli/latest/reference/kinesis/index.html#cli-aws-kinesis>.

Solution

aws kinesis — Interact with the Amazon Kinesis Data Streams, a service that scales elastically for real-time processing of streaming big data. 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}}

Code Snippets

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

Context

tldr-pages: common/aws kinesis

Revisions (0)

No revisions yet.