sample code to put record to kinesis firehose

kinesis-firehose-sample.py

# Message in payload should be single-line minimized json + newline '\n' append at the end of each line:
# eg: 
# {"id": 111, "name": "QiQi", "email": "[email protected]"}
# {"id": 222, "name": "Hello", "email": "[email protected]"}
# {"id": 333, "name": "tv", "email": "[email protected]"}

import boto3
import json

client = boto3.client('firehose', aws_access_key_id='aaa', aws_secret_access_key='bbb', region_name='eu-west-1')

payload1 = json.dumps({
    'id': 111,
    'name': 'QiQi',
    'email': '[email protected]'
})

response1 = client.put_record(
    DeliveryStreamName='tv-stream-test',
    Record={'Data': payload1 + '\n'}
)

print(response1)

###### Put Records in Batch ######

payload2 = json.dumps({
    'id': 222,
    'name': 'Hello',
    'email': '[email protected]'
})

payload3 = json.dumps({
    'id': 333,
    'name': 'tv',
    'email': '[email protected]'
})

response2 = client.put_record_batch(
    DeliveryStreamName='tv-stream-test',
    Records=[{'Data': payload2 + '\n'}, {'Data': payload3 + '\n'}]
)

print(response2)