Stream a Kinesis shard on the Commandline

getstream.sh

#!/usr/bin/env bash
# prereqs: awscli, awslocal (for now), jq

set -e

streamname=$1
iteratorType=${2:-LATEST}

shard=$(awslocal kinesis describe-stream --stream-name $streamname --query 'StreamDescription.Shards[0].ShardId' --output text)
iterator=$(awslocal kinesis get-shard-iterator --stream-name $streamname --shard-id $shard --shard-iterator-type $iteratorType --output text)
while output=$(awslocal kinesis get-records --shard-iterator $iterator); do
  iterator=$(echo $output | jq -r '.NextShardIterator')
  records=$(echo $output | jq -r '.Records[].Data')
  for record in $records; do
    echo "----START RECORD----"
    echo $(echo $record | base64 -D)
    echo "----END RECORD----"
  done
done