Celery

Try it in 3 steps

1. 1

   Install Celery 5.6.3

   Pin the reviewed stable release. Python 3.9 or newer and a RabbitMQ server reachable on localhost are required.

   python -m pip install "celery==5.6.3"Copy
2. 2

   Create a minimal task application

   Follow the minimal application shown in the official README and configure RabbitMQ as the broker.

   cat > tasks.py <<'PY' from celery import Celery app = Celery('hello', broker='amqp://guest@localhost//') @app.task def hello(): return 'hello world' PYCopy
3. 3

   Start a worker and enqueue a task

   Run the worker in one terminal, enqueue the task from another, and confirm receipt and execution in the worker log.

   celery -A tasks worker --loglevel=INFO # In another terminal: python -c "from tasks import hello; print(hello.delay())"Copy

Built with

• Python

Categories and tags

GitHub data

Share a guide or use case for this OSS in Markdown. Articles are published after administrator approval.

Explore next

• Asynq13,748 Stars

  2 shared tag(s) · 1 shared category(s)

  distribute background tasks to Redis-backed worker queues with retries and scheduling

  Go
• Sarama12,523 Stars

  2 shared tag(s) · 1 shared category(s)

  cover Kafka producers, consumer groups, administration, and transactions from Go

  Go
• kafka-go8,638 Stars

  2 shared tag(s) · 1 shared category(s)

  use high-level Reader and Writer APIs or drop down to a low-level pure-Go Kafka connection

  Go
• Lapin1,237 Stars

  2 shared tag(s) · 1 shared category(s)

  connect Rust services to RabbitMQ over AMQP 0-9-1 with runtime-agnostic async APIs

  Rust
• Dask13,932 Stars

  2 shared tag(s) · Same language

  scale parallel analytics with NumPy/pandas-like collections and lazy task graphs

  Python
• TensorFlow200,710 Stars

  2 shared tag(s)

  machine-learning infrastructure with important Python and dependency changes in 2.21

  C++