celery-task

0熱

1答えて

新しいタスクが処理されるたびにタスク履歴レコードを作成するタスクがあります。タスク関数の先頭に新しいTaskHistoryインスタンスをインスタンス化します。何らかの理由で、前のタスクで割り当てられたTaskHistoryクラスの属性が、後続のタスクでTaskHistoryクラスの属性に割り当てられています。それが失敗する可能性があり、後続のタスクで task_history.meta['succ

0熱

1答えて

Celery Python同期タスク

私のアプリケーションでは、残りのAPIに接続するPythonセロリのタスクがあります。問題は、APIが同じ資格情報で複数の再取得を許可しないことです。キューにこれらのAPIタスクをブロックする方法はありますか？意味、複数のリクエストが同じ時刻に発生した場合、タスクをキューに入れて、1つずつ実行して、キューの最初のものが終了するのを待つことができますか？現在、rabbitmqメッセージキュー（

1熱

2答えて

セロリが時間を設定してもcrontabタスクを送信しない

セロリー4.1を使用していて、crontabタスクで時間を設定する以外は、すべての定期タスクが正しく機能します。私はタイムゾーンの設定と関係があると思っていましたが、問題がどこにあるのか分かりません。ダッシュボード/ celery.py from __future__ import absolute_import, unicode_literals from celery import Cel

0熱

1答えて

のPython-セロリログイン

私はでログファイルを作成したいフラスコ、Pythonの3.xおよびcelery4 （合計8人の労働者）を使用する「RotatingFileHandler」ファイルサイズを超えている場合は分割します。最初のログファイルで正常に動作します。（それは、すべての労働者にはログインが含まPoolWorker-1〜PoolWorker-8） -rw-rw-r-- 1 sj sj 1048530 9월 1

3熱

2答えて

Celery add_periodic_taskブロック

私は、プロジェクト設定のディクショナリリスト（django.conf.settingsからインポートされたもの）に基づいて、定期的にセロリタスクを動的に追加するモジュールを作成しました。私は設定で指定された特定のuuidで呼び出される関数add_tasksそのスケジュール機能使用していることを実行します。 def add_tasks(celery): for new_task in s

0熱

1答えて

セロリのタスクの表示名

私はセロリのタスクをいくつか持っています。タスクIDを使用してAsyncResultをインスタンス化することによって、別々のプロセスから定期的に状態をチェックしています。これから、私はタスクの状態を取得します。 hereのようにカスタム結果バックエンドと拡張AsyncResultクラスを実装することで、タスク名も取得できます。しかし、私は各タスクのカスタム表示名を得ることができます。人間が読める

12熱

1答えて

セロリーadd_consumerが呼び出された後にワーカーがタスクを消費しない

Celery（RabbitMQをバックエンドMQとしている）を活用して、さまざまなキューからさまざまなフレーバのタスクを実行したいと考えています。 1つの要件は、特定のキューからの消費者（作業者による）が一時停止して再開する能力を持つ必要があることです。セロリは、this capabilityと表示されており、add_consumerとcancel_consumerと呼びます。特定のワーカーの待