kinesis-util.py

import boto3
from common import session

current_session = session.get_session('qa')
client = current_session.client('kinesis')

response = client.put_record(
    StreamName='bdc-kinesis-qa',
    Data=b'<sample></sample',
    PartitionKey='1',
    StreamARN='arn:aws:kinesis:eu-west-1:xxxxxxxxxx:stream/kinesis-name'
)

# response = client.get_records(
#     ShardIterator='shardId-000000000068',
#     Limit=123,
#     StreamARN='arn:aws:kinesis:eu-west-1:xxxxxxxx:stream/kinesis-name'
# )

response = client.put_record(
    StreamName='stream name',
    Data=b'test',
    PartitionKey='shardId-000000000000',
    StreamARN='arn:aws:kinesis:eu-west-1:xxxxxxx:stream/kinesis'
)