django-celery

    10

    2答えて

    real-time monitoring of celery workersに関するセロリのチュートリアルによれば、ワーカーによって生成されたイベントをプログラムで捕捉し、それに応じてアクションを実行することもできます。 私の質問は、thisの例として、セロリ-Djangoアプリケーションでモニタを統合するにはどうすればいいですか? 編集:だから私は、作業者によって送られtask_failedイベ

    8

    3答えて

    セロリのシンプルなサンプルをプロダクションサーバーにデプロイしようとしています。セロリのウェブサイトでデーモンhttp://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing 、およびI は、/ etc/default/celeryd 1 # Name of nodes to start

    50

    2答えて

    私はセロリとジャンゴ・セロリーを使用しています。私は、テストしたい定期的なタスクを定義しました。定期的なタスクをシェルから手動で実行して、コンソール出力を表示することは可能ですか?

    8

    1答えて

    2つの異なるサーバーを使用してタスクを処理するセロリがセットアップされています。私は、タスクが完了したサーバーを照合する最良の方法を理解しようとしています。私はドキュメントを見て、AsyncResultからホスト名を取得することについて何も見ていませんでした。 この件に関するご意見はありがとうございます。私が試して考えていたもう一つの選択肢は、単にセロリの各設定にホスト名を入れることです。しかし、

    8

    2答えて

    私はDjangoアプリケーションで作業しています。セロリを使用してMongoデータベースに書き込みをキューイングしています。私はセロリに何かをキューに入れる機能のために、機能テスト(Seleniumを使って)を書こうとしています。 セロリは、テストデータベースの代わりにメインのMongoデータベースに書き込むという問題があります。テストデータベースに書き込むセロリのインスタンスを処理するために機能

    10

    2答えて

    処理のためにタスクをエンキューする小さなスクリプトがあります。このスクリプトは、エンキューする必要のあるアイテムを取得するためのデータベースクエリをたくさん作成します。私が直面している問題は、スクリプトによってエンキューされるとすぐに、セルリーワーカーがタスクを開始することです。これは正しく、セロリが動作する方法ですが、これはしばしばスクリプトとセロリの労働者の間のデッドロックにつながります。 ス

    13

    2答えて

    いくつかのタスクを実行するセロリチェーンがあります。それぞれのタスクは失敗し、再試行できます。簡単な例は以下を参照してください: from celery import task @task(ignore_result=True) def add(x, y, fail=True): try: if fail: raise Exception('Ugly ex

    5

    3答えて

    私はCeleryを実行しており、すべてがうまくいきます。 セロリはデフォルトでデータベース結果を格納するデータベーステーブルを使用します。これはcelery_taskmetaです。このテーブルは非常に速く成長しています。私はドキュメントを読んでいましたが、古いエントリのクリーンアップについてのヒントは見つかりませんでした。 celerybeatによってタスクが自動的にスケジュールされていますか?こ

    9

    1答えて

    セロリでどのようにタスクをクリーンアップするのかを理解しようとしています。 古い結果が CELERY_TASK_RESULT_EXPIRES設定に基づいて、自動的に消去されます:the task docsを見てから、私はそれを参照してください。デフォルトでは、これは1日後に の期限が切れるように設定されています。非常に混雑しているクラスタの場合は、 の値を下げる必要があります。 しかし、この引用は

    6

    1答えて

    Celery 3.0のチェーンを使用して作成された実行中のワークフローを一時停止/再開する方法はありますか? 基本的に私たちのシステムには、対話型と非対話型の2種類のタスクがあります。非対話型のものにはすべてのパラメータがありますが、対話型のものにはユーザー入力が必要です。インタラクティブタスクの場合、結果は対話型タスク(つまり、実際のチェーンを作成する前にユーザー入力を求めることはできません)に