About This Architecture
Event-driven Salesforce CDC pipeline leveraging AWS Lambda, SQS, and OpenRouter AI for real-time contact activity processing. Change data capture events flow from Salesforce through a Lambda listener into SQS queues, where workers orchestrate AI model inference via Step Functions with ElastiCache rate limiting. The architecture ensures reliability through FIFO deduplication, dead letter queues, CloudWatch alarms, and SNS alerting while persisting results to RDS and S3 cold storage. Ideal for teams automating CRM intelligence workflows with fault-tolerant, scalable serverless patterns. Fork this diagram on Diagrams.so to customize queue configurations, swap AI providers, or add additional processing stages.