celery - celeryd が実行されていない場合、その task.delay または task.apply_async が失敗するように指定することは可能ですか?

Question

djcelery と djkombu を使用しています。私はRabbitMQを使用していましたが（推奨オプションであるため）、RabbitMQはVPSでメモリを使いすぎており、私は安っぽいです。

私のコードがタスクをスケジュールしようとしていて、celeryd が実行されていない場合、私のアプリで例外がスローされると良いと思います。これは、スーパーバイザー、nagios などによって celeryd を監視するための一種のバックアップ プランです。

最初は設定でこれができると思ってimmediateいましたが、私の Django ORM 設定ではうまくいきませんでした。

Answer 1

問題は主に、このコマンドを使用してブローカーに単純なメッセージを送信していることです。基本的に、ブローカーはメッセージを保存し、誰かがそれを消費するのを待ちます。このアーキテクチャの優れた点は、セロリワーカーが2ダウンした場合、再度実行すると、ブローカーにあるすべての古いスケジュールされたタスクのフェッチを開始することです。プロジェクトでこの動作を望まない場合は、セロリが間違った選択である可能性があります。