私はdjangoプロジェクト内でセロリを使用しています。毎分実行されるセロリのスケジュールされたタスクがあり、開始する新しいタスクがあるかどうかをデータベース内でチェックします。また、設定されたタスクには時間の開始と期間があります。
この定期的なタスクの仕事は次のとおりです。
- 新しい非同期タスクが構成されている場合は、新しい非同期タスクを開始します。(タスク.遅延(...))
- 前に開始したタスクが実行中かどうかを確認する
- 期間を超えたタスクを停止する (app.control.revoke(...))
- ....その他のもの...
しかし、問題は次のとおりです。定期的なタスク内で開始された非同期タスクのステータスを監視するための「ベストプラクティス」は何ですか?
つまり、スケジュールされたタスクが実行されるたびに、DB から構成されたすべてのタスク (開始、開始など) を取得しますが、関連するセロリ タスク ID が関連付けられていません。関連するタスク celery に関連付けられた db タスクを実行するには?
ジャンゴセロリは私を助けることができますか?
ありがとう。