AWS KinesisAWS Kinesis

Producer → [Shard 1] → Consumer (Lambda, EC2, Kinesis Analytics)
         → [Shard 2] →
         → [Shard N] →

- Shard: 초당 1MB 쓰기 / 2MB 읽기 처리 단위
- 보존 기간: 기본 24시간, 최대 365일
- 파티션 키: 데이터를 특정 샤드로 라우팅

import boto3, json

kinesis = boto3.client('kinesis', region_name='ap-northeast-2')

def put_record(stream_name, data, partition_key):
    response = kinesis.put_record(
        StreamName=stream_name,
        Data=json.dumps(data),
        PartitionKey=partition_key
    )
    return response['ShardId']

put_record('my-stream', {'user_id': 123, 'action': 'click'}, 'user-123')