celery

0熱

1答えて

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

0熱

1答えて

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

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

-1熱

2答えて

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

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

0熱

1答えて

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

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

0熱

2答えて

UbuntuサービスUpstartまたはSystemD、サービスとしてのDjango開発サーバー

私はPython & Django Frameworkをしばらくの間、Ubuntu 16.01で作業してきました。私はQシステム（Celery）や他のいくつかの拡張アプリケーションでDjangoを使っていました。毎回すべてのアプリケーションを実行しようとすると、開発サーバー "{python manage.py runserver}"を実行してから、セロリーワーカー "{セロリー-Aファイル名ワー

0熱

3答えて

ビルドドッカーのイメージレベル=エラーmsg = "タールライターを閉じることができません：io：閉じたパイプでの読み取り/書き込み"

time="2017-10-27T07:39:20Z" level=error msg="Can't add file /var/app/current/app/content_classifier/forest.pickle to tar: io: read/write on closed pipe" time="2017-10-27T07:39:20Z" level=error msg="C

1熱

1答えて

Celeryマルチワーカーで自動スケーリングを有効にする方法は？

コマンドcelery worker -A proj --autoscale=10,1 --loglevel=infoは、自動スケーリングでワーカーを開始します。私は自動スケーリングするマルチを有効にするにはどうすればよいのマルチ、 [email protected]:~/projects/x$ celery multi start myworker --autoscale=10,1 celer

1熱

1答えて

djangoからメッセージを消費する

djangoでセロリを使用してrabbitmqからメッセージを消費することはできますか？メッセージはセロリが実行されるメソッドの名前が含まれている作成し、それをパラメータリストだメッセージの異なる非Djangoのアプリから import os from celery import Celery from django.conf import settings os.environ.set

2熱

1答えて

order_create（）は2つの引数をとります（1が与えられます）

私はセロリのタスクを実行しようとしていました。 task.py from .models import OrderItem from cart.cart import Cart from .forms import OrderCreateForm @task(name="create_order") def create_order(request): cart = Cart(

0熱

2答えて

デベロッパーとプロダクションに同じrabbitmqを使用するとセロリのキューを保護する方法

私はrabbitmqとセロリをバックエンドタスクに使用していますが、dev/testと同じrabbitmqを使用したいと思いますが、誰かが誤って製造待ち行列のためにセロリの労働者を出し、dev/testのためにそれらを使用します。可能であれば、同じrabbitmqバックエンドにもアクセスできるセロリのワーカーが、セロリのキューにアクセスするのを防ぐ方法を教えてください。