1

セロリでタスクに再試行するように指示すると、何が起こっているのか教えていただけますか?同じワーカースレッドで再試行しますか、それとも他の場所に送信する可能性のあるブローカーに返されますか?

ワーカーまたはディスパッチャが突然停止した場合、再試行のタスクはどうなりますか?タスクが失われる可能性がある場合、これを回避するためのアプローチはありますか?各タスクをデータベースに保存し、しばらく結果が得られない場合は再試行できますか?

または、ディスパッチャが独自の永続ストレージを持っている可能性がありますか?タスクの受信中または実行中にワーカースレッドがクラッシュした場合はどうなりますか?

4

1 に答える 1

1

セロリでタスクに再試行するように指示すると、何が起こっているのか教えていただけますか?同じワーカースレッドで再試行しますか、それとも他の場所に送信する可能性のあるブローカーに返されますか?

はい、タスクは異なる推定実行時間でブローカー(Rabbit MQなど)に戻ります

ワーカーまたはディスパッチャが突然停止した場合、再試行のタスクはどうなりますか?タスクが失われる可能性がある場合、これを回避するためのアプローチはありますか?各タスクをデータベースに保存し、しばらく結果が得られない場合は再試行できますか?または、ディスパッチャが独自の永続ストレージを持っている可能性がありますか?タスクの受信中または実行中にワーカースレッドがクラッシュした場合はどうなりますか?

ここで完全な回答が失われたタスクまたは失敗したタスクを再試行します(Celery、Django、RabbitMQ)

于 2011-03-17T13:22:25.210 に答える