redisでcelerly 2.5.1を実行しています。celerymon や celeryev に表示されるセロリのタスクと同じタスク情報を取得したいと考えています。あれは:
celeryev 2.5.1
││ UUID WORKER TASK TIME STATE
││ 59587fe7-b83f-4cf3-8343-6abdfbc016e7 watson-thinkpad app.task 18:14:03 RECEIVED
ただし、ドキュメントとさまざまな投稿からのパスは 2 つしかありません。
result = task.AsyncResult(task_id)
result.get()
これは、celeryev からのより有益な行ではなく、タスクのコールバックが返したものを取得します。
そして、竜巻プロセスのコンテキストでセロリからの情報を処理するために、コンシューマー、レシーバー、および別のスレッドを設定することを含む、セロリモンで使用される方法があります。
ただし、私が探しているのは、前者のような単純な呼び出しフォームですが、後者によって詳細な情報が提供されます。celeryev にあるため、情報を動的に更新する必要はありません。一度だけ表示されます。
別のイベントループまたはスレッドをスピンアップせずに、Python用の既存のセロリ2.5 APIでこれを行う方法はありますか? 可能であれば、追加の複雑さは避けたいと思います。
ありがとう。