問題タブ [django-celery]

django celeryを使用してプロジェクトを開始し、「djcelery.urls」によって提供されるタスクURLに対してajax呼び出しを行っています。

このデータについていくつか知りたいのですが。

1. その情報はどこに保存されていますか？djangoプロジェクトデータベースのdjceleryテーブルから呼び出されますか、それともRabbitMQサーバーに保持されますか？私のデータベースのdjceleryテーブルについての私の理解は、それらがカメラを使用して使用状況を監視するためだけのものであるということです。

2. RabbitMQサーバーに保存されている場合、タスクステータスレポートはどのくらいの期間利用できますか？このデータはどのくらいのメモリを消費しますか？

3. メモリリークを防ぐために、タスクステータスレポートを定期的にフラッシュする必要がありますか？これはどのように行われますか？rabbitmqサーバーを再起動しますか？

ありがとう。

djkombuキューでセロリを使用しています。

私はmax_retries=3自分のタスクを設定しました。3 回目の再試行が失敗すると、 でafter_returnメソッドが実行されstatus=FAILUREます。このメソッドはtask_idパラメーターも受け取ります。これtask_idで、タスクを手動で再開できますか ( を 1 に設定する必要があると思いますMessage.visible) ?

私は2つの異なるdjangoプロジェクトを持ってprojAおりprojB、それぞれが別々のキューで実行されている独自のセロリデーモンを持っていますが、同じvhost、projAにはタスクがtaskAあり、projBにはタスクがあります。たとえば、内部taskBから実行しようとしていますtaskBtaskA

taskB が 1 秒以内に終了したことを projB のログで確認できますが、taskA は結果を待ち続け、20 秒後にタイムアウトします

バックエンドにはrabbitmqがあります。

電子メールの送信に失敗した場合、タスクがデータベースの更新をロールバックするトランザクション タスクを実行しようとしています。

以下は私のコードですが、ここで何が間違っているのかアドバイスできますか?

hereから特定の時間に特定の間隔で実行するようにタスクを設定できることがわかりましたが、それはタスク宣言中にのみ行われました。タスクを定期的に動的に実行するように設定するにはどうすればよいですか?

バックグラウンドで大量のメールを送信できるように、Celery で Django をセットアップしようとしています。

さまざまなコンポーネントが Celery でどのように機能するかについて、少し混乱しています。RabbitMQ を使用する必要がありますか? 「django-kombu」だけでセロリを実行できますか? ( http://ask.github.com/celery/tutorials/otherqueues.html#django-database )

django-celery ドキュメント ( http://django-celery.readthedocs.org/en/latest/getting-started/first-steps-with-django.html ) の「Django の最初のステップ」から始めましたが、 「セロリワーカーサーバーの実行」に到達すると、次のことが起こります。

その後、プロセスを終了する必要があります...

私は今朝CeleryとRabbitMQをいじり始め、サーバーのパフォーマンスがどのように向上するかを確認するためにいくつかの基本的なタスクを定義しました。

私はrabbitmqユーザー、vhostsを追加し、権限を設定しました。RabbitMQサーバーを起動しました

非常に詳細なチュートリアルで、これらの人がcelerybeatとcelerydを使用して、いくつかのタスクのステータスを確認し、それらを実行していることがわかりました。

RichLelandによる詳細なチュートリアル

どういうわけかセロリも必要ですか、それとも私が取った手順は十分ですか？

これに関する情報やメモはどこにも見当たりませんでした...ただ尋ねるだけです

手動のトランザクション管理で Django - Celery タスクを実行したいのですが、アノテーションがスタックしないようです。

例えば

結果は

一方、アノテーションの順序を逆にすると、

それは理にかなっていますが、良い回避策を見つけるのに苦労しています。Django のドキュメントには、注釈の代替手段については言及されていません。必要がない場合は、各セロリ タスクのクラスを作成したくありません。

何か案は？

私が使う：

1. セロリ
2. Django-Celery
3. RabbitMQ

Django管理ページですべてのタスクを確認できますが、現時点では次のようないくつかの状態があります。

• 受け取った
• リトライ
• 取り消されました
• 成功
• 開始しました
• 失敗
• 保留中

それは私にとって十分な情報ではありません。実行中のプロセスに関する詳細を管理ページに追加することはできますか？プログレスバーや完成したジョブカウンターなどのように。

セロリのログ機能の使い方は知っていますが、私の場合はGUIの方がいいと思います。

では、トレース情報をDjango-Celery管理ページに送信することは可能ですか？

特定のタスクをバックグラウンドで定期的に (たとえば 1 時間または 2 時間ごとに) 実行する必要がある動的サイトの展開を計画しています。出力する必要があるデータは、これらのクエリの結果に厳密に依存しています。

問題は、これらのタスクには一定の時間がかかることです (例: 8 ～ 10 分)。したがって、ユーザーがページを要求すると、特定のビューが呼び出され、そのタスクがまだ処理中である場合、すべてがうまくいきません。

では、ここで質問です。その問題を処理するには、何を実装する必要がありますか? 私は検索してセロリについて見つけましたが、上記の問題を修正するためにどのように使用できるか理解できず、タスクがまだ終了していないときに介入するキャッシュシステムを実装する可能性があります.