In [ ]:

    

import boto3


    

In [ ]:

    

from os import environ


    

In [ ]:

    

client = boto3.client('kinesis',
             aws_access_key_id=environ.get('PROD_ID'),
             aws_secret_access_key=environ.get('PROD_KEY')
            )


    

In [ ]:

    

client.list_streams()


    

In [ ]:

    

params = {
    'StreamName': 'ObservationStream',
    'PartitionKey': 'arbitrary',
    'Data': b'I did a thing'
}


    

In [ ]:

    

client.put_record(**params)


    

In [ ]:

    

client.describe_stream(StreamName='ObservationStream')


    

In [ ]:

    

shard_iter_params = {
    'StreamName': 'ObservationStream',
    'ShardId': 'shardId-000000000000',
    'ShardIteratorType': 'TRIM_HORIZON'
}


    

In [ ]:

    

shard_iter = client.get_shard_iterator(**shard_iter_params)


    

In [ ]:

    

shard_iter


    

In [ ]:

    

client.get_records(ShardIterator=shard_iter['ShardIterator'])