This chapter covers the core features and capabilities of Event-Driven Architecture Kit.
| Category | Files | Description |
|---|---|---|
| Terraform | sqs_sns_topology.tf, eventbridge_rules.tf, kinesis_streams.tf, variables.tf | IaC for SQS/SNS fan-out, EventBridge routing, and Kinesis streaming |
| CloudFormation | event-bus-stack.yaml, sns-fanout-stack.yaml | EventBridge custom bus and SNS fan-out pattern stacks |
| Scripts | event_schema_validator.py, event_flow_visualizer.py, dlq_processor.py | Schema validation, flow visualization, and DLQ replay tools |
| Docs | architecture.md, event_patterns.md, troubleshooting_guide.md | Architecture diagrams, pattern catalog, and debugging guide |
| Examples | event_schemas/*.json, event_catalog.yaml | Event schemas for order, payment, and inventory domains |
Pattern 1: Fan-Out (SNS → SQS) Pattern 2: Event Bus (EventBridge)
┌─────────┐ ┌─────────────┐
│ Producer │──→ SNS Topic │ Producer │──→ EventBridge Bus
└─────────┘ │ └─────────────┘ │
├──→ SQS Queue A (Service A) ├──→ Rule 1 → Lambda
├──→ SQS Queue B (Service B) ├──→ Rule 2 → SQS
└──→ SQS Queue C (Analytics) └──→ Rule 3 → Step Functions
Pattern 3: Streaming (Kinesis) Pattern 4: DLQ + Replay
┌─────────┐ ┌─────┐ ┌─────┐ ┌─────┐
│ Producer │──→ Kinesis Stream │ SQS │──✗─│ DLQ │──→ │Replay│
└─────────┘ │ └─────┘ └─────┘ └─────┘
├──→ Lambda Consumer │
├──→ Firehose → S3 ▼
└──→ Analytics Back to SQSFollow this guide to get Event-Driven Architecture Kit up and running in your environment.
cd terraform/
terraform init
terraform plan -var="environment=production" \
-var="project_name=my-platform" \
-var="alert_email=team@example.com"
terraform applyaws cloudformation deploy \
--template-file cloudformation/event-bus-stack.yaml \
--stack-name my-event-bus \
--parameter-overrides \
ProjectName=my-platform \
Environment=production \
--capabilities CAPABILITY_IAM# Validate a single event against its schema
python scripts/event_schema_validator.py \
--schema examples/event_schemas/order_events.json \
--event '{"event_type": "order.created", "order_id": "ORD-001", "total": 99.99}'
# Validate all events in a file
python scripts/event_schema_validator.py \
--schema examples/event_schemas/order_events.json \
--events-file my_events.jsonl# Preview messages in DLQ (dry run)
python scripts/dlq_processor.py --queue-url https://sqs.eu-west-1.amazonaws.com/123456789012/my-dlq --dry-run
# Replay messages back to source queue
python scripts/dlq_processor.py --queue-url https://sqs.eu-west-1.amazonaws.com/123456789012/my-dlq --replayGet the full Event-Driven Architecture Kit and unlock everything.
Get the complete guide with every chapter unlocked, including code samples, diagrams, and best practices.
Access all interactive tools with complete data, all workload profiles, and the full scenario library.
Downloadable source code, configuration files, and working examples from every chapter.
Free updates for life. Every new chapter, tool, and improvement included.