python - Celery: Python タスクからキューを選択的にクリアする

Question

偶発的な不要なタスクで Celery キューが蓄積され、サーバーが詰まる状況が時々あります。たとえば、コードは 1 ではなく 20 000 のタスクを実行します。

Celeryキューに含まれるPythonタスクを調べて、特定のタスクを選択的に取り除くにはどうすればよいですか?

タスクは、標準の Celery デコレーターで定義および開始されます (問題がある場合)。

@task()
def update_foobar(foo, bar):
    # Some heavy activon here
    pass

update_foobar.delay(foo, bar)

スタック: Django + セロリ + RabbitMQ。

Answer 1

多分あなたは花を使うことができます。これは、優れた Web インターフェイスを備えた Celery のリアルタイム モニターです。そこからタスクをシャットダウンできると思います。とにかく、キューに入れられた不要なタスクを避けようとします。