json_to_firehose.py

# usage json_to_firehose.py input_file.json my_firehose_stream
import json
import sys
import boto3
 
client = boto3.client('firehose')

filename = sys.argv[1]
streamname = sys.argv[2]

with open(filename) as f:
    d = json.load(f)

    event_str = json.dumps(d)

    resp = client.put_record(DeliveryStreamName=streamname,
            Record={
                'Data': event_str
            }
    )