celery

0熱

1答えて

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

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

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

0熱

1答えて

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

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

-2熱

1答えて

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

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

0熱

2答えて

Celeryの実行後もRedisにデータが残っています

RabbitMQをブローカとして、Redisをバックエンドとして使用しているCeleryタスクを設定しました。実行後、私のRedisサーバーはまだ多くのメモリを使用していたことに気付きました。検査の結果、作成されたタスクごとにキーが残っていることがわかりました。セロリに応答を受け取った後にのみこれらのキーをクリーンアップする方法はありますか？私はいくつかのMessageBrokersがacksを

1熱

1答えて

Django-regristration-reduxでセロリを使用して登録時にメールを送ろう

登録と放浪のためにdjango-registration-reduxを使用しています。セロリを追加することができます。サインアップ？おかげ

6熱

1答えて

セロリタスクでgrpcのタイムアウトが発生する

セロリタスクでGRPCサーバーに接続しようとしています。私はPythonのシェルを介してこのスニペットを実行すると、私は接続を確立し、GRPCメソッドを実行することができる午前コード timeout = 1 host = '0.tcp.ngrok.io' port = '7145' channel = grpc.insecure_channel('{0}:{1}'.f

1熱

1答えて

セロリのタスクは、失われているワーカーにキューイングされるべきです

私はdjango-celery 3.2とcelery 3.1.25を使用しています。は、私は設定の下に追加されました - ImportError: No module named vine.five ステップ3.2 を再現するために、次のエラーで CELERY_TASK_ACKS_LATE = True task_reject_on_worker_lost = True アプリケーションの

0熱

2答えて

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

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

0熱

1答えて

kubernetes pod for celery

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