python - Celery - コマンド ラインまたは HTTP リクエストを介してタスクをアクティブ化する

Question

私のコードには、定義済みのセロリタスクがあります。my_proj.tasks.my_celery_task

(アプリケーション経由ではなく) コマンドライン/HTTP リクエストを介してタスクをアクティブ化したいと考えています。

ドキュメントを検索しました (saw flower および curl オプション) が、定義済みのタスクを呼び出す実際の良い例はありません。これを達成する方法は？

Answer 1

セロリコマンドラインを使用できます

タスクを呼び出す

# Positional arguments
celery call my_celery_task --args='[1,2]' --broker <broker_url>
# Keyword arguments
celery call my_celery_task --kwargs='{"x":1, "y":2}' --broker <broker_url>
# Returns the task-id

結果を得る

celery result <task_id> --result-backend <backend_url>

---

セロリ アプリケーションで同じブローカーとバックエンド セットを選択する必要があります。