Super simple AWS Kinesis data streams client in Python

Marius Bio
Feb 7, 2021

Your Kinesis streams is collecting data and you need a simple and fast way to access those data for testing purpose or a custom processing. You can achieve this in 3 steps:

  1. Get the shard id.
  2. Get the shard iterator.
  3. Get the records.

Follow those steps in any programming language supported by AWS API. Here’s an example written in Python:

For more advanced processing, consider using the Kinesis Client Library.

--

--

Marius Bio

Software engineer based in Quebec city, QC. I enjoy coding, data analysis, tennis and photography (https://mariusbio.photos).