celery

    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
    python django celery 2017-10-31

    0熱

    1答えて

    Celery Python同期タスク

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

    1熱

    1答えて

    Celeryタスクの実行前にDjangoモデルのセーブ方法を教えてください。

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

    0熱

    1答えて

    flask-sqlalchemyでフラスコ - rqを使用するとResourceClosedErrorが発生する

    最近、フラスコ - rqをflask-sqlalchemyで使用して、モデル操作で非同期タスクを実行しました。 Modelメソッドを呼び出すときに時々エラーが発生しましたが、ResourceClosedErrorエラーが発生します。私は、問題を引き起こすために私のrq-workerに何が起こるか分かりません。問題を正しく再現できませんでした。ここにスニペットがあります。 （いくつかの非同期タスクが
    python asynchronous sqlalchemy celery flask-sqlalchemy 2017-11-03

    0熱

    1答えて

    セロリの代わりにPythonのバックグラウンドタスクのために

    私はフラスコを使用しています。私はセロリのように動作するPythonの代替を探していました。 @app.route('/') def loop(): for i in range(1000000): print(str(i)) sys.stdout.write(str(i)+ '\n') return "done" 代わりに：例えばのために @ce
    python celery 2017-11-07

    0熱

    1答えて

    Python Celeryタイプインポートアプリケーションエラーの登録解除されたタスクを受け取りました

    メインのPythonアプリケーションからタスクを実行するためにセロリアプリケーションをインポートできません。私はmyprogram.pyファイルからセロリのタスクを実行できるようにしたい。次のように マイcelery_app.pyファイルは次のとおりです。 import celery app = celery.Celery('MyApp', broker='redis://localhost:
    python import celery 2017-11-07

    -2熱

    1答えて

    スクリプト内で直接Python関数を実行すると、Flaskアプリケーションコントローラ内から対話します。

    次の動作を理解するのは苦労しています。 私は特定のモバイルペイメントAPIを統合しています。支払機能を実行すると、支払APIが呼び出され、要求の受領を確認する応答を返し、ユーザーの携帯電話でSTKPush画面を放した直後に返信する必要があります（APIは、モバイル支払を扱う電気通信会社によって提供されます）。私は最初に単純なPythonスクリプトを書いて統合をテストし、うまく機能しました。以下は、
    python flask celery stk uss 2017-11-07

    0熱

    2答えて

    RabbitMQからセロリを処理しない

    メッセージングバックエンドとしてRabbitMQを使用して、「longjobs」というキューからタスクを処理するようにCelery 4.1ワーカーを設定しました。 My Celeryの設定と作業者は、Django 1.11プロジェクトによって管理されます。 何もエラーは発生しませんが、私のDjangoアプリケーションから起動されたタスクは私のワーカーによって決して拾われません。 マイcelery.
    python django rabbitmq celery 2017-11-09

    0熱

    1答えて

    kubernetes pod for celery

    セロリ、ラビットMQ、フラワーで分散タスクの仕組みを実行する必要があります。 通常、私のケースでは3つのポッドを作るサービスごとに別々のポッドを作成します。私の質問は3ポッドを作る理由です。 3つの容器で1つのポッドを作成できます。サービスは緊密に結合されており、実用的なソリューションを得るためにはすべて実行している必要があります。 3つの容器に1つのポッドの代わりに3つのサービスに3つのポッドを
    rabbitmq kubernetes celery 2017-11-10

    3熱

    2答えて

    Celery add_periodic_taskブロック

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