lambda

Overview ¶

Lambda binary for the recently-interacted-topk example.

Reads Segment-style interaction events from Kinesis (via Lambda's Kinesis trigger) and folds them into the shared TopK sketch in DynamoDB. Pair with the cmd/worker binary that consumes a parallel Kafka topic — both write to the same DDB row, so the merged TopK reflects interactions from BOTH channels.

Build (Lambda runs the `provided.al2` runtime):

GOOS=linux GOARCH=arm64 go build -tags lambda.norpc \
    -o bootstrap ./examples/recently-interacted-topk/cmd/lambda
zip lambda.zip bootstrap

Deploy via your Lambda toolchain of choice (SAM / CDK / Terraform). The event-source mapping should set:

FunctionResponseTypes = ["ReportBatchItemFailures"]
BatchSize             = 100..1000 (tune per processing time)
StartingPosition      = LATEST  (or TRIM_HORIZON for full backfill)