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.

Files for celery-cloudwatch-logs, version 1.7
Filename, size File type Python version Upload date Hashes
Filename, size celery-cloudwatch-logs-1.7.tar.gz (5.4 kB) File type Source Python version None Upload date Hashes View

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page