AWS Lambda
How to Send Data to Kinesis Firehouse in Python?
- Last updated Apr 25, 2024
Here's an example code to send data to Amazon Kinesis Firehouse in Python:
import boto3
import json
firehouse_client = boto3.client('firehose')
def send_firehose(data):
try:
record = {"Data": json.dumps(data)}
response = firehouse_client.put_record(
DeliveryStreamName='my-firehose-stream-name',
Record=record)
print('Response from firehouse = ', response)
except Exception as ex:
print("Error :",ex)
#Sending data to firehouse
data = [{"name":"abc","id":"1"},{"name":"efg","id":"2"}]
send_firehose(data)