SysPadExamples › Serverless data pipeline

Serverless data pipeline

IoT-style ingestion: HTTP API to a buffering Lambda, a Kinesis stream, a processor Lambda writing to DynamoDB + an S3 lake, with Athena queries and a Glue catalog.

A fully serverless, event-driven pipeline with async boundaries and the analytics tier.

Ingest API API Gateway AT LIMIT Ingest Lambda Lambda Event Stream Kinesis AT LIMIT Processor Lambda Device State DynamoDB Data Lake S3 Glue Catalog Glue Athena Queries Athena AT LIMIT

How it works

Event Stream
The ingest API returns once events land here; every step after runs async off the stream.

Request flows

Device event ingestion

  1. Ingest API
  2. Ingest Lambda
  3. Event Stream
  4. Processor
  5. Device State
  6. Data Lake

Scheduled crawl & query

  1. Data Lake
  2. Glue Catalog
  3. Athena Queries

Other reference architectures

Open this architecture in SysPad · All examples