python - 既存のセロリワーカープロセスに動的に関数を追加しますか？

Question

私はセロリを始めていますが、すでに開始されているセロリプロセスにモジュールを追加できるかどうか知りたいです。つまり、celeryconfig.pyを介してモジュールを追加する代わりに

CELERY_IMPORTS = ("tasks", "additional_module" )

ワーカーを開始する前に、ワーカープロセスの開始後に、後で何とかしてadditional_moduleを使用できるようにします。

前もって感謝します。

Answer 1

拡張されたインポートリストを使用して新しいcelerydを開始し、最終的に（現在のジョブが終了した後）古いワーカーを正常にシャットダウンすることで、目標を達成できます。

ジョブをプッシュする非同期の性質のため、セロリが作業を終了した後にのみジョブにマークを付けるため、実際にこの方法で作業を行うことを見逃すことはありません。同じマシンでセロリワーカーを実行できるはずです。セロリワーカーは、RabbitMQ（または使用するキューバックエンド）への新しい接続として表示されるだけです。