celery-task

1熱

1答えて

CeleryのTaskクラスをオーバーライドしたいと思います。私はon_successメソッドとon_failureメソッドをオーバーライドできますが、runメソッドはそれほど簡単ではありません。私はbindメソッドを使用しようとしました。 class MyTask(Task): def on_success(self, retval, task_id, args, kwargs):

0熱

1答えて

Flask Socket.IO Redisエラーが発生しましたが、RabbitMQを使用しています

Flaskでアプリケーションを作成しています。メッセージブローカーとしてもRabbitMQを使用しています。私はまた、SocketIOを使ってセロリのワーカーのステータスをクライアントに報告します。アプリを実行しているときに次のエラーが表示されます。なぜこのエラーが発生するのか教えてください。 app.py app = Flask(__name__) app.config['SECRET_KE

0熱

1答えて

デフォルトのセロリカウントダウン

djangoのsettings.pyのデフォルトのカウントダウンタイマーをCELERYD_TASK_SOFT_TIME_LIMITのように宣言する方法はありますか？それは私のクラスベースの定期的なタスクのようにいつもそれを宣言するのではなくて、役立つでしょうか？ try: ddd except Exception as exc: raise self.retry(exc=ex

0熱

1答えて

別のアプリケーションのセロリキューからコンシューマする方法

Celeryを使用してRabbitMQにAPIコールを挿入するための私のプロデューサアプリケーションには、以下のコードがあります。 celery.send_task('tasks.process_redox', (payload,), queue="redox_inbound") 私は、そのキューから消費するコードはどのように見えますか？あなたはそのキューを監視するためにセロリを指示する必要が

1熱

1答えて

既存のグループまたはコードにタスクを追加

次のシナリオを検討してください。 3種類のタスクがあります。 A,BおよびC。 Aは、Bの入力を生成することを意味し、Bは、Aから入力を受け取った後に多くのCのタスクを作成することになっています。最初にgroup(A, B)を定義できるのは、CがBであるためです。しかし、私はすべてのCタスクが完了するのを待って、メインタスクが完了したと結論づけたいと思っています。セロリのユーティリティを使って

0熱

1答えて

Djangoスタートでセロリを実行

私はDjango 1.11とCelery 4.0.2を使用しています。私たちは、kubernetes - Dockersを走るPaaS（OpenShift 3）を使用しています。私はPython画像を使用しています、それは起動時に一つのコマンドを実行します（終了コードのために従ってください - 失敗した場合に再起動）する方法だけを知っている、がどのように私はDjangoを実行している同じ時間

0熱

1答えて

セールスコードでタスクが実行されないようにするタスクオプション

デッドロックを防ぐために、既存のセロリグループコールをコードに変換しようとしています。前のコードには再試行と有効期限がありました。私はその設定を使わずにコードを動かすことができましたが、設定を適用しようとすると、実行されているタスクは表示されません。私は全体的に和音に同じ設定を適用することに関する文書では何も見ませんでした。私はセロリのバージョン3.1.6を実行しています。前のコード： jobs

2熱

1答えて

は、各ワーカープロセスごとに、またはアプリケーションごとに1回ずつ初期化されたCelery Taskですか？

私は初期化に時間がかかり、多くのメモリを消費する重い外部ライブラリクラスを持っています。タスクインスタンスごとに最低1回は作成したいと思います。 class NlpTask(Task): def __init__(self): print('initializing NLP parser') self._parser = nlplib.Parser()

0熱

1答えて

Celery-rabbitmqでタスクの依存関係を処理する人

Celeryの初心者として本当に混乱しています。クライアント（ipython）がCelery Canvasを使用してDAGを送信すると、rabbitmqがメッセージ依存関係を処理する方法についていくつかの入力が必要ですワークフロー）プリミティブ（チェーン、コード、グループなど） A（> B、C） - > D（Diamond DAG）ここでAが最初に実行され、BとCが並行してBとCの出力が使用される

1熱

1答えて

セロリのタスク

のためのパラメータとして、それを使用するために、Redisのに文字列のバイトを送信する私はブローカーとしてのRedisを使用してセロリのタスクに文字列内のバイトを送信したいが、私は以下のようにエラー受けています： [2017-06-17 21:27:13,826] ERROR in app: Exception on /endpoint_method [POST] Traceback (most