2020-10-24 14:27:02 +01:00
|
|
|
# aws kinesis
|
|
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
> Offizielles AWS CLI für die Amazon Kinesis-Streaming-Datenplattform.
|
2021-04-24 12:09:56 +01:00
|
|
|
> Weitere Informationen: <https://docs.aws.amazon.com/cli/latest/reference/kinesis/index.html#cli-aws-kinesis>.
|
2020-10-24 14:27:02 +01:00
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
- Liste alle Streams auf:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
|
|
|
|
`aws kinesis list-streams`
|
|
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
- Schreibe einen Datensatz in einen Kinesis Stream:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
`aws kinesis put-record --stream-name {{name}} --partition-key {{schlüssel}} --data {{base64_codierte_nachricht}}`
|
2020-10-24 14:27:02 +01:00
|
|
|
|
2022-10-10 15:10:50 +01:00
|
|
|
- Schreibe einen Datensatz in einen Kinesis Stream mit base64 inline Encodierung:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
`aws kinesis put-record --stream-name {{name}} --partition-key {{schlüssel}} --data "$( echo "{{meine nachricht}}" | base64 )"`
|
2020-10-24 14:27:02 +01:00
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
- Liste alle verfügbaren Shards in einem Stream auf:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
|
|
|
|
`aws kinesis list-shards --stream-name {{name}}`
|
|
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
- Rufe einen Shard Iterators auf, um diesen beginnend mit der ältesten Nachricht auszulesen:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
|
|
|
|
`aws kinesis get-shard-iterator --shard-iterator-type TRIM_HORIZON --stream-name {{name}} --shard-id {{id}}`
|
|
|
|
|
|
2021-03-25 16:42:04 +00:00
|
|
|
- Lies einen Datensatz aus einem Shard über einen Shard Iterator:
|
2020-10-24 14:27:02 +01:00
|
|
|
|
|
|
|
|
`aws kinesis get-records --shard-iterator {{iterator}}`
|
