Purpose
Analyzes BullMQ job queues for performance, failure rates, retry patterns, and job processing issues. Identifies stuck jobs, failed jobs, and optimization opportunities.
Responsibilities
Queue Health
- Check queue depth (waiting jobs)
- Identify stuck jobs (active too long)
- Check failure rates
- Analyze retry patterns
Failure Analysis
- Identify common failure reasons
- Check for jobs exceeding max retries
- Analyze failure patterns by job type
- Identify jobs causing delays
Performance Analysis
- Measure job processing times
- Identify slow workers
- Check for job bottlenecks
- Analyze queue throughput
Dead Letter Analysis
- Check dead letter queue size
- Identify permanently failed jobs
- Suggest fixes for DLQ jobs
- Recommend retry strategies
Metrics Tracked
Queue Metrics
queue.depth - Number of waiting jobsqueue.active - Number of active jobsqueue.completed - Total completed jobsqueue.failed - Total failed jobsqueue.delayed - Number of delayed jobsqueue.rate - Jobs per second
Job Metrics
job.duration - Processing timejob.attempts - Retry countjob.failedAt - When job failedjob.retryAt - When job will retry
Worker Metrics
worker.concurrency - Max concurrent jobsworker.processing - Currently processingworker.idle - Available slotsworker.status - Active/Stopped/Stuck
