2
まず、悪い英語をお詫びしたいと思います。不適切なブローカーURLを使用してタスクを公開すると、セラーがハングアップする
私はフラスコで安らかなセロリを使用しています。セロリのタスクを公開しようとすると、プロセス全体が無期限にハングアップします。これは、セロリの設定でブローカのURLの値を正しく指定しなかった場合に発生します。
どうすれば修正できますか?タスクパブリッシュのタイムアウトを設定する方法と、タスクをパブリッシュする最大再試行回数を設定する方法はありますか。
私はtask_publish_retryディレクティブをFalseに設定しようとしましたが、それは私の仕事ではありません。
有効なブローカーURLを指定できない理由はありますか? – Tim
私はこの問題を自分で処理したい。有効なbroker_urlの問題だけではなく、ブローカがダウンしている場合は、これを処理する必要があります。 – Vir
@Vir私はDjangoとCeleryを統合するのと同じ問題があります。私はRabbitMQインスタンスをシャットダウンして、ブローカーが応答せずに永遠にぶら下がっているときのCeleryの動作をテストします。 Celeryのコードを掘り下げた後、ブローカ接続の初期化時に接続タイムアウトとmax_retriesが渡されないようです。あなたはどんな解決策を見つけましたか? –