celery

3熱

2答えて

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

4熱

2答えて

ドッカーインスタンスでredisに接続できないセラー作業者

セロリタスクを使用するDjangoアプリケーションを実行しているドッキング設定があります。セロリはブローカーとしてレディスを使用します。バージョン：ドッカーバージョン17.09.0-CE、afdb6d4 ドッキングウィンドウ・コンバージョン1.15.0をビルドし、e12f3b9 のDjango == 1.9.6 ジャンゴを構築-celery-beat == 1.0.1 セロリ== 4.1.0

0熱

2答えて

Celery and Rabbit MQ Django

私は、コマンド： pip install celeryとsudo apt-get install rabbitmqでCeleryとRabbitMQをインストールしました。セロリは機能しません。私はこのエラーを取得： Traceback (most recent call last): File "/home/morilon/dj/shop/lib/python3.5/site- pa

0熱

1答えて

多くのRabbitMQブローカと1つのセロリアプリケーション

私は多くのRabbitMQブローカとシングルセロリアプリケーションを持っています。すべてのブローカーからのすべてのメッセージをこの1つのアプリケーションにルーティングしたいと考えています。これを行う最も簡単な方法は何ですか？私はそれがRabbitMQブローカー間の連合を作成することによって行うことができることを知っています、私はそれを行う別の方法があることを知りたいと思います。

1熱

2答えて

各タスクインスタンスの有効期限を設定したセラースケジュールタスク？

私はセロリ4.1.0でdjangoアプリを持ち、データベーススケジューラでセロリを打ちました。私が望むのは、管理サイトから定期的なタスクを実行し、各タスクの有効期限を設定することです。 PeriodicTaskのexpireプロパティは、タイムスケジューラがそのタスクの新しいメッセージの作成を停止しますが、スケジュールされているが古い値よりも古いタスクを失効させたいとします。一時間。これを行う方法

0熱

1答えて

rabbitmqで現在処理されているメッセージを確認するにはどうすればいいですか？

セロリとrabbitmqには新しく、私はいつrabbitmqに表示されないのですか？メッセージは処理されますか？ Here is a list of queue that have been created

0熱

1答えて

Djangoユーザーは、ユーザーのis_activeを1分間偽に設定して再びアクティブにします。

私はpost_save信号の受信機を持っており、同じユーザーの複数のアクティブアクセストークンを検出して制限しています。さらに、この検出されたユーザーを1分間ロックし、ユーザーのis_activeフィールドを使用して再度ユーザーを再度アクティブにしたいとします。アカウントロックの開始時刻を保存するために新しいモデルを作成して使用することなくこれを行う方法はありますか？また、私は予定されている仕

0熱

1答えて

mongodbでのセロリタスクに関する追加情報の保存

タスクに関する追加情報をMongoDBに保存します。たとえば、タスクを作成したユーザーのIDです。 { "_id" : "a77db490-d090-4c9d-a48c-b6f766bee902", "status" : "SUCCESS", "result" : "8", "date_done" : ISODate("2017-11-17T10:16:28

0熱

1答えて

virtualenvにあるdjangoでセロリを実行する必要があるときにスーパーバイザを使う方法は？

昨日、nginx、uwsgi、celery、supervisorを使ってDjangoプロジェクトを配備しました。すべてはうまく見えた。しかし、いくつか質問があります。私はDjangoプロジェクトを展開し、ローカルのPythonインストールを使用しましたが、仮想環境でPythonを使用する必要がある場合、どうすればよいですか？例えば、私はdjangoサイトがいくつかのタイミングタスクを制御する

2熱

1答えて

不適切なブローカーURLを使用してタスクを公開すると、セラーがハングアップする

まず、悪い英語をお詫びしたいと思います。私はフラスコで安らかなセロリを使用しています。セロリのタスクを公開しようとすると、プロセス全体が無期限にハングアップします。これは、セロリの設定でブローカのURLの値を正しく指定しなかった場合に発生します。どうすれば修正できますか？タスクパブリッシュのタイムアウトを設定する方法と、タスクをパブリッシュする最大再試行回数を設定する方法はありますか。私はt