Put Records and Read Back

Put Records and Read Back

Batch-put records, then read them back from the landing shard.

1. Write the batch of records in a single call and capture the shard id of the first result entry to read from.
2. Obtain a TRIM_HORIZON shard iterator for the shard the first record landed on, positioning the reader at the oldest record in the shard.
3. Read the records back from the shard using the iterator, returning the retrieved records and the next iterator for continued reading.

What you'll need to have ready

• streamName: The name of the Kinesis data stream to write to and read from.
• records: The records to write, each an object with Data (Base64) and PartitionKey.

For your developer

Arazzo workflow amazon-kinesis:put-records-and-read-back, 3 operations: PutRecords → GetShardIterator → GetRecords. Specs on APIs.io.