celery

    0

    1答えて

    アムのRabbitMQからのメッセージを消費しますが、消費者は、その後 [MainProcess] Received message: RT @Iamsidneyy: Kenya in scientific terms [WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!? The

    0

    2答えて

    セロリーが比較的新しいです。セロリのタスクの1つは、他のタスクがすべて終了した後に開始する必要があります。私はそれを使って遊びました。また、オンラインでいくつかのドキュメントを見つけました。私はgroupsとchordsなどを使って、完全に理解できないはずです。 私はまた、SO hereの別の質問を掲載しましたが、今までのところ納得のいく回答は見つかりませんでした。 最後に私はthis SO qu

    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(

    2

    1答えて

    私はDjangoの1.11プロジェクトを持っているという名前のない: env myproject myapp myotherapp settings settings.py __init__.py celery_init.py マイ__init__.pyが含まれています from .celery_init import app a

    0

    2答えて

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

    2

    1答えて

    task.py @task(name="send_mail_to_custormer") def order_created(order_id): order = Order.objects.get(id=order_id) subject = 'Order nr. {}'.format(order.id) message = 'Dear {} {},\n\nYou

    0

    1答えて

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

    1

    1答えて

    Django 1.11 + MySQL + Celery 4.1プロジェクトでは、ビューで新しいユーザーレコードが作成され、次にCeleryタスクを起動して関連する長期実行アクションを実行します。 この場合の典型的な問題は、Celeryタスクを実行する前にユーザー作成がデータベースにコミットされていることです。それ以外の場合、競合状態が発生し、タスクは、トランザクションがコミットする前に実行される

    0

    2答えて

    私はceleryとrabbitmqを使って、約1,000万のタスクを処理しています。タスクの出力は、リモートrabbitmqに格納されているjsonです。私はPikaを使って、リモートのrabbitmqの異なるキューにメッセージを公開していました。現在、私はpikaが非同期ではないので、このエラーpika.exceptions.ConnectionClosed: Connectionを取得していま

    1

    2答えて

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