問題タブ [celerybeat]

これは非常によく似た問題に対処しているようですが、十分な洞察は得られません: https://github.com/celery/billiard/issues/101 非 SQLite データベースを試すのは良い考えのようです。 ..

django アプリを使用した簡単なセロリのセットアップがあります。私のsettings.pyファイルでは、次のように実行するタスクを設定しました。

ここの指示に従いました: http://celery.readthedocs.org/en/latest/django/first-steps-with-django.html

2 つの新しいターミナル ウィンドウを開いて、次のようにセロリ プロセスを実行できます。

ONE - スケジュールされたタスクに必要で、タスクをキューに入れるセロリ ビート プロセス:

TWO - タスクをキューから取り出して実行するセロリ ワーカー:

ただし、タスクが送信されると、約 50% の時間でワーカーがタスクを実行し、残りの 50% の時間で次のエラーが発生するようです。

Mavericks を実行している Macbook Pro で開発しています。

セロリ バージョン 3.1.9 RabbitMQ 3.2.3 Django 1.6

私はdjango-celery 3.1.9を使用しており、djceleryアプリを有効にしていることに注意してください。

RedisToGo Nanoアドオンを使用してHerokuでセロリビートを使用しています

1 つの Web dyno と 1 つのワーカー dyno があります

celerybeat ワーカーは、毎分タスクを実行するように設定されています。

問題は次のとおりです。新しいコミットをデプロイするたびに、dynos が再起動し、このエラーが発生します

それらのログは際限なく続きます。両方のdynoを停止して再起動するまで。

新しいコミットがデプロイされるたびに発生するため、問題になっています。

なぜこれが起こっているのか、これを解決する方法はありますか?

Windows 7でCelery Beatを使用して定期的なタスクを設定するのに本当に苦労しています（残念ながら、それが現在対処していることです）。セロリを使用するアプリは CherryPy で作成されているため、Django ライブラリはここでは関係ありません。私が探しているのは、Celery Beat Process をバックグラウンドで開始する方法の簡単な例です。FAQセクションには次のように書かれていますが、実際にはまだできていません：

ウィンドウズ

worker への -B / –beat オプションが機能しない?¶

答え: そうです。代わりに、セロリ ビートとセロリ ワーカーを別のサービスとして実行します。

私のプロジェクトのレイアウトは次のとおりです。

セロリ.py:

タスク.py

celery_schedule.py

コマンド ラインから ("proj" の親ディレクトリから) "celery worker --app=proj -l info" を実行すると、ワーカー スレッドが正常に開始され、Python ターミナルから追加タスクを実行できます。ただ、ビートサービスの起動方法がわかりません。欠落している --beat オプションを通過していないため、明らかに構文も間違っている可能性があります。

毎分実行される 2 つのタスクを設定しようとしています。それらを 1 つにグループ化して実行する方法はありますか?

私は次のように指定CELERYBEAT_SCHEDULEしましたceleryconfig.py：

では、2 つのタスクを実行したい場合、次のようになると思いますか?

しかし、うまくいきませんでした。これを行う標準的な方法はありますか？

セロリのドキュメントに従って、開発マシンで 2 つのキューを定義しました。

私のセロリ設定：

プロジェクトの virtualenv で 2 つのターミナル ウィンドウを開き、次のコマンドを実行しました。

私が得たのは、すべてのタスクが両方のキューで処理されているということです。

私の目標は、定義された 1 つのタスクのみを処理する 1 つのキューと、CELERY_ROUTES他のすべてのタスクを処理するデフォルト キューを持つことです。

また、このSO question、rabbitmqctl list_queuesreturns celery 0、および running rabbitmqctl list_bindingsreturnsexchange celery queue celery []を2回実行しました。ウサギのサーバーを再起動しても何も変わりませんでした。

私の関数は 1 つの引数を取ります。しかし、私はそれを 1 つのワーカーで複数の引数に対して呼び出したいと考えています。「args:」で異なる引数を呼び出すにはどうすればよいですか、または複数の引数を定義するにはどうすればよいですか。

Celery ワーカーと cron ジョブ用のセロリ ビートを使用して Django サイトを実行しています。スーパーバイザーが再起動されたとき、またはスーパーバイザーのジョブが再起動されたときに、不正なセロリ ビート プロセスが実行され続けることがあります(正確にいつ発生するかはわかりません)。基本的に、これらのタスクを複製する 2 つのセロリ ビート プロセスが実行されることになります。1 つのタスクがリマインダー メールを送信し、これが発生すると多くのユーザーが重複したメールを受信するため、これは問題です。

セロリビートとスーパーバイザーで同様の経験をした人はいますか。セロリビートプロセスが常に1つだけ実行されていることを確認する方法はありますか?