Question

How can you process data from AWS Kinesis Streams?

Answer 1

You can process data from Kinesis Streams using AWS Lambda, EC2 instances, or Kinesis Data Analytics. Here’s a basic example using AWS Lambda and Python:

import base64
import json

def lambda_handler(event, context):
    for record in event['Records']:
        # Decode and process each record
        payload = base64.b64decode(record['kinesis']['data']).decode('utf-8')
        data = json.loads(payload)
        # Your processing logic here
        print(data)