Question

How do you use AWS Kinesis Firehose?

Answer 1

Here’s an example of using AWS Kinesis Firehose to deliver data to an Amazon S3 bucket:

import boto3

# Initialize Firehose client
firehose = boto3.client('firehose')

# Example data
data = {
    'sensor_id': 'sensor001',
    'temperature': 25.5,
    'humidity': 60.2
}

# Put record into the Firehose delivery stream
response = firehose.put_record(
    DeliveryStreamName='your-delivery-stream-name',
    Record={
        'Data': json.dumps(data) + '\n'
    }
)

print(response)