Skip to main content

Uploads results of Celery tasks to AWS CloudWatch.

Project description

This is a simple monitoring tool that intercepts the results of Celery tasks and uploads the result to AWS CloudWatch.


Install from PyPi:

pip install celery-cloudwatch-logs


Configuration is done through environment variables. The following environment variables must be set in order for celery-cloudwatch to work:




Optionally, the following environment variables may be set:

  • REDIS_URL="redis://"


The CloudWatch log group does not have to exist. If it doesn’t exists, it will be created.


$ celery cloudwatch

This requires you to have ran or installed this package through pip. Alternatively, run:

$ python -m celery_cloudwatch

How it works

Celery CloudWatch connects to your broker and monitors tasks in real time. When a task succeeded, failed was rejected or revoked, it uploads all available information about that task into a log stream on AWS CloudWatch Logs.

Based on the specified log group name in the AWS_CLOUDWATCH_GROUP_NAME, a log group will be created. For each possible result, a separate log stream is created. For each task result, an entry is added to the log stream associated with the result.

Known issues

  • --broker on celery cloudwatch is ignored.

  • No descriptive way to specify other brokers than Redis.

All brokers supported by Celery will work, simply specify the broker URL through the REDIS_URL environment variable.

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

celery-cloudwatch-logs-1.7.tar.gz (5.4 kB view hashes)

Uploaded source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page