celeryradar-sdk 0.1.1

Celery monitoring SDK — task events, worker heartbeats, beat schedules, and queue depths.

celeryradar-sdk

Celery monitoring SDK for CeleryRadar. Hooks Celery's standard signals to ship task events, worker heartbeats, beat schedules, and queue depth — no agents, no sidecars, no broker plugins.

What gets monitored

• Task events — start, success, failure, retry, runtime, exception type
• Worker heartbeats — online/offline detection per worker hostname
• Beat schedules — fires, misses, and drift from the expected interval
• Queue depth — Redis broker depth per queue (cluster supported; RabbitMQ and SQS planned)

Install

pip install celeryradar-sdk

Use

import celeryradar_sdk

celeryradar_sdk.connect(api_key="cr_...")

That's it. The SDK is async and non-blocking — if the ingest endpoint is slow or unreachable, your workers don't notice; events drop with a warning rather than back up your task queue.

How it differs from Flower

Flower is a real-time inspector and admin tool — great for browsing the current task queue and revoking tasks. CeleryRadar is the persistence layer above it: history, alerts, dashboards, and trend analysis. They don't conflict.

Documentation

• Quick start — get connected in five minutes
• Configuration — every kwarg and env var
• How the SDK works — async ingest, retry queue, fork safety
• What gets monitored — signals and detection
• Troubleshooting — common issues and fixes

License

MIT