celery-task

    0

    1答えて

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

    0

    1答えて

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

    12

    1答えて

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

    1

    1答えて

    セロリを後でフラスコのアプリケーションに組み込む方法を学びたいと思っています。私はちょうどCelery Docsにある基本的な例を実行しようとしています。私はtask.pyと呼ばれるファイルを作成しました。そこには、ファイルtask.pyが存在します。私はセロリを実行しています-A tasks workers --loglevel = infoエラーを出しています。何が間違っているのかわからない。

    0

    1答えて

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

    1

    1答えて

    セロリーを学ぶには、Celery Best Practicesと読んでください。セロリーでのデータベース使用については、非常に簡単な質問があります。 デニBertovicは言う: あなたがシリアライズされたオブジェクトが古い データが含まれている可能性があるため、バックグラウンドタスクを する(例えば、あなたのUserモデルのための)データベースオブジェクトを渡すべきではありません。 @app.t

    0

    1答えて

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

    7

    2答えて

    私たちの非同期バックグラウンドタスクにはセロリが使用されています。異なる優先度のタスク用に2つのキューがあります。 2つのノードクラスタが別々に提供されています。物事は期待通りにうまくいっています。 質問: 私たちは、主に低優先度のタスクを取得します。リソースの使用率を最適化するため、両方のキューを待機するワーカー(優先度の高いキューを待機する)を構成する方法があるのだろうかと思います。しかし、あ

    1

    2答えて

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

    3

    2答えて

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