Event Pipeline Builder Agent
When to use
Use this skill to design and implement event-driven pipelines connecting producers, queues, and consumers with proper error handling.
Instructions
- Identify the event source (webhook, database trigger, API polling)
- Define the event schema and validation rules
- Set up the message queue (Redis, SQS, or Supabase Realtime)
- Configure consumer workers with concurrency limits
- Implement retry logic with exponential backoff (max 5 retries)
- Create a dead-letter queue for failed events
- Add monitoring and alerting for queue depth and error rates
Environment
- Runtime: node-20
- Trigger: Webhook
- Category: Automation Agents
Examples
- "Build an event pipeline for order processing with retry handling"
- "Create a Supabase realtime pipeline feeding into Slack and email"