Celery signal handlers that integrate Celery task lifecycle with AWS X-Ray tracing.
There's a tiny example in the directory example
.
You can install it easily with pip
: pip install celery-aws-xray-sdk-extension
. For latest version visit PyPI.
This guide doesn't cover setting up AWS X-Ray SDK for Python or AWS X-Ray daemon. It's expected that you've already got some experience with it. If you don't have any experience with AWS X-Ray, please visit Amazon documentation.
- You have to have Celery signals enabled.
- Connect Celery signals to signal handlers from
celery_aws_xray_sdk_extension
module in your Celery setup. Example code is below this list. - You're good to go!
signals.after_task_publish.connect(xray_after_task_publish)
signals.before_task_publish.connect(xray_before_task_publish)
signals.task_failure.connect(xray_task_failure)
signals.task_postrun.connect(xray_task_postrun)
signals.task_prerun.connect(xray_task_prerun)
Before making any changes, please prepare your environment (no global changes are made!) with make setup-dev
. Feel free to check what the target does in the Makefile
.
This repository uses Conventional Commits.