celery-task

1熱

2答えて

だから、私は比較的単純な問題があると思うので、それを使ってレンガの壁を打っているようです。私はフラスコのアプリケーションと、セロリ& redis（ブローカー）を使用してサーバー側で多数のスクリプトを実行できるWebページを持っています。それから私がしたいすべての、私はそれに名前/ IDを与えるために、タスクを起動したときである（タスクは、クライアント側のボタンとして描かれる）すなわち @app.

0熱

1答えて

Celery send_taskと例外時に再試行

例外が発生したときには、retry（official doc）のタスクを実行します。セロリはretryをself.retry(...)の形で使用します。私はクラスなしの関数を持っているので、私はどのようにユーザselfを使用するのか分かりません。私のコードは、この .. imports ... app = Celery('elasticcelery') @app.task(name='rm

-2熱

1答えて

セロリで条件付きサブタスクのチェーンを作成するにはどうすればよいですか？

私は、実行する一連のタスクを作成するアプリケーションを作成していますが、チェーンは、そのピースが追加されるというユーザーの希望に応じてタスクを実行します。ユーザーがstart_booしたい場合例えば、チェーンは次のようになります。fooとbazがすでに開始されている場合 def start_boo(): chain = start_foo.s() | start_bar.s() | s

0熱

2答えて

Pythonセロリ - コード内のすべてのサブタスクを待つ方法

私はセロリのタスクをユニットテストしています。チェーンタスクもグループを持っているので、コードが生成されます。テストは次のようになります。実行セロリタスク（遅延）をタスクとすべてのサブタスクアサート待ち、私は次のことを試してみました： def wait_for_result(result): result.get() for child in result.chil

0熱

1答えて

HTTPリクエストでCeleryタスクIDを使用するのは安全ですか？

FlaskベースのWebアプリケーションでCeleryを使用して、サーバー側で非同期タスクを実行し始めました。いくつかのリソースは、ユーザ/クライアント先の「/アクション」サブリソースを取得するには、例えば、アクションを指定するJSON-体を含むPOSTを送信することができます： curl -H "Content-Type: application/json" -X POST \ -d

10熱

3答えて

照会するデータベースにセロリジョブの引数を入力する方法。 mysqlを使用して

私はセロリの結果バックエンドとしてMySqlを使用しています。 DBにもプログラム引数を格納したい。例えば：私は後で照会することができるように、DB内のユーザー引数を保存する。この場合 add.apply_async(args=[num1, num2, user] 。現在、DBに格納されている引数を返します。 def add(num1, num2, user): return [

3熱

1答えて

celeryのすべてのログをカスタムハンドラに送信する方法。私の場合はpython-logstashのハンドラ

私のCeleryアプリケーションでは、セロリのアプリケーションログとタスクレベルのログの2種類のログを取得しています（ログのlogger.INFO（str）構文を使用しています）私はsettings.pyでハンドラやロガーを設定することで、私は成功したDjangoのログ用のカスタムハンドラ（私の場合のpython-logstashハンドラ）にそれらの両方を送りたいと思ったが、私はセロリ

3熱

1答えて

Flask Celery update_state from another function

セロリタスクの状態を別の関数から更新したいと思います。ここで私は今持っているものです。ルート @app.route('/my-long-function', methods=['POST']) def my_long_function(): param1 = request.form['param1'] param2 = request.form['param2']

2熱

1答えて

セルラーワーカーがネットワーク変更/ IP変更に再接続しない

私の職場で実行する必要があるタスクのためにセロリを導入しました。これらのタスクは巨大で、これらを実行するためにいくつかのハイスペックマシンを購入しました。私に展開3機で労働者別のリモートサーバ上のタスクをプッシュし、リモートサーバープロデューサーの RabbitMQのブローカーを：I詳細私の問題の前に、私が展開されてきたものすべてについて、私は簡単にしましょう職場私が始めたとき、すべてのプロ

1熱

1答えて

セロリのタスクは、プロジェクト内からモジュールのImportErrorをインポートできません。

以下のエラーは、セロリの労働者を通過した場合にのみ発生することに注意してください。ターミナルで次のコマンドを使用して： celery -A MarketPlaceTasks worker --loglevel=info Traceback (most recent call last): File "/usr/lib/python2.7/dist-packages/celery/a