celery

    0熱

    1答えて

    RabbitMQを最初のメッセージ送信時に1回だけ実行させるにはどうすればよいですか？

    私はRabbitには本当に新しく、この質問に関連する正確な用語や、これを実行する最良の方法を検索する方法がわかりません ユーザーがページに到達したときに呼び出されるタスクがあります。私はそのページがその日に1回実行されるようにしたい。より多くの人がそのページにアクセスすると、タスクは既に実行されているので実行されません。誰もそのページに行っていない場合、そのタスクは決して実行されません。 誰かが私
    rabbitmq celery 2017-10-10

    1熱

    1答えて

    特定のセロリタスクのETAパラメータを変更することはできますか？

    私が使用して実行セロリタスクOセットがあります。 my_task.apply_async(args, eta=some_eta) しかし、時にはにより、私はこれらのタスクのETAを変更する必要がある特定の条件を。 inspectとscheduledの方法を使用してタスクのIDを取得できます。タスクのIDを知っているETAパラメータを変更する方法があるか、このタスクを取り消して別のものを開始する
    python celery 2017-10-10

    0熱

    1答えて

    セロリタスクを再試行しませ

    私は再実行されていない、失敗したタスク次の内容の簡単なtest_celery.pyファイルがあります：私は、タスクを実行するときに from celery import Celery import time app = Celery( 'test_celery', broker='amqp://', backend='amqp' ) @app.task(re
    python celery 2017-10-10

    0熱

    1答えて

    セロリのタスクからイベントを発行する方法

    基本的に、別のスレッドでサーバー側でイベントを生成しようとしています。私はcelery.taskイベントを放出すべきですが、そのコードは決して実行されません。 import json import time from celery import Celery from flask import Flask from flask import jsonify from flask im
    python flask celery flask-socketio 2017-10-10

    0熱

    1答えて

    セロリはいつも熱心に実行していますが、タスクは非同期です

    CELERY_ALWAYS_EAGER=False私のページを読み込むと、私のウサギはメッセージを受け取りますが、消費することはありません。 CELERY_ALWAYS_EAGER = Trueの場合、私の仕事は消費されますが、私のページはいつも仕事を終えるのを待っているのでロードされており、こうしてherokuにtimeoutが作成され、エラーが発生します。 ここでサークルに参加します。セロリの
    celery 2017-10-11

    -1熱

    2答えて

    Pythonは20秒ごとにcronジョブを実行します

    私は常にcronを実行するためにセロリの定期タスクを使用していますが、今回はセロリのcrontabが自分のcronジョブを実行できません。私はだけが火曜日に20:50から21:10まで20秒ごとに実行されるクロムが必要です。これを達成できないようです
    python cron celery 2017-10-11

    1熱

    1答えて

    Daphneはウェブソケットを聞いていません

    クライアントとサーバの通信にウェブソケットを使用するdjango-channels + celeryで書かれたWebアプリケーションがあります。 daphneを実行してテストした後、セロリのワーカーと私のホストマシン上でredisを実行すると、ドッカーですべてをカプセル化し、展開可能なシステムにすることにしました。 ここで問題が発生しました。私はdocler-compose.yamlを学習、調整、
    python django websocket celery daphne 2017-10-11

    0熱

    1答えて

    Flaskでコミットが成功した後にセロリタスクを実行しますか？

    比較的長時間にわたるタスクは、別のサーバー上で別々に実行されているセラーワーカーに委任されます。 しかし、結果はリレーショナルデータベースに戻されます（task_descr.idに従って更新されたテーブル、以下を参照）。ワーカーはignore_resultを使用します。フラスコアプリケーションから要求された タスク： task = app.celery.send_task('tasks.mytas
    flask transactions celery race-condition 2017-10-13

    2熱

    2答えて

    セロリを再起動する方法Supervisordによって実行されたWroker

    スーパーバイザを使用して生産中のセロリを実行しています。私の監督者の構成は以下の通りです。 [program:celeryd] command=%(ENV_PROJECT_PATH)s/scripts/celery_worker.sh stdout_logfile=%(ENV_PROJECT_PATH)s/celeryd.log stderr_logfile=%(ENV_PROJECT_PA
    python django celery django-celery supervisord 2017-10-18

    0熱

    1答えて

    セロリのタスクが既に起動しているかどうかを知る方法

    私はセロリの作業を開始できるフラスコのアプリケーションを持っています。この作業は、私が一度だけ起動したいデーモンのようなものです。だから私が望むのは、その状態を監視し、タスクなどから何らかのメッセージを表示することです。これはすべてうまくいきます。 私はそれを行う方法を理解できませんが、フラスコのアプリケーションでは、起動後にタスクIDを取得する方法があります。私ができる仕事を始めたら @main
    python flask celery 2017-10-19
最新の質問