Dramatiq

Try it in 3 steps

1. 1

   Install Dramatiq 2.2.1 with RabbitMQ support

   Pin the reviewed release and RabbitMQ broker dependency. Python 3.10 or newer and RabbitMQ on localhost are required.

   python -m pip install "dramatiq[rabbitmq]==2.2.1"Copy
2. 2

   Create a minimal actor

   Use the actor/message pattern from the official Quickstart with a minimal task that does not require external HTTP access.

   cat > example.py <<'PY' import dramatiq @dramatiq.actor def add(x, y): print(f'{x} + {y} = {x + y}') if __name__ == '__main__': add.send(2, 3) PYCopy
3. 3

   Start a worker and send the message

   Start the worker, enqueue the message from another terminal, and confirm 2 + 3 = 5 in the worker log.

   dramatiq example # In another terminal: python example.pyCopy

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

• OpenTelemetry Python2,656 Stars

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

  instrument Python traces, metrics, and logs through the OpenTelemetry API and SDK

  Python
• 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