Dramatiq

3ステップで試す

1. 1

   Dramatiq 2.2.1とRabbitMQ対応を導入する

   確認対象の安定版とRabbitMQ broker依存を固定して導入します。Python 3.10以上とlocalhostのRabbitMQが必要です。

   python -m pip install "dramatiq[rabbitmq]==2.2.1"コピー
2. 2

   最小actorを作る

   公式Quickstartと同じactor/message構成で、外部HTTP accessを必要としない最小taskを作ります。

   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) PYコピー
3. 3

   workerを起動してmessageを送る

   workerを起動した状態で別端末からmessageをenqueueし、worker logに2 + 3 = 5が表示されることを確認します。

   dramatiq example # 別端末で: python example.pyコピー

Built with

• Python

カテゴリとタグ

GitHubデータ

このOSSの使い方や活用事例をMarkdownで投稿できます。管理者が承認した後に公開されます。

あわせて探訪

• OpenTelemetry Python2,656 Stars

  共通タグ 2件 · 共通カテゴリ 1件 · 同じ言語

  trace・metrics・logsを共通API/SDKで扱うPython向けOpenTelemetry実装

  Python
• Asynq13,748 Stars

  共通タグ 2件 · 共通カテゴリ 1件

  Redis-backed queueでbackground taskをretry・schedule・workerへ分散するGo library

  Go
• Sarama12,523 Stars

  共通タグ 2件 · 共通カテゴリ 1件

  Producer・Consumer Group・Admin・Transactionを幅広く扱うGo Kafka client

  Go
• kafka-go8,638 Stars

  共通タグ 2件 · 共通カテゴリ 1件

  Reader・Writerと低level Connを使い分けるpure Go Kafka client

  Go
• Lapin1,237 Stars

  共通タグ 2件 · 共通カテゴリ 1件

  RabbitMQへAMQP 0-9-1で接続するruntime非依存のasync Rust client

  Rust
• Dask13,932 Stars

  共通タグ 2件 · 同じ言語

  NumPy・pandasに近いcollectionとtask graphでparallel analyticsを拡張する

  Python