キュー内のまだ処理されていないタスクのリストを取得するにはどうすればよいですか?
ベストアンサー1
編集: キュー内のタスクのリストを取得する方法については、他の回答を参照してください。
こちらをご覧ください:セロリガイド - 作業員の検査
基本的には次のようになります:
my_app = Celery(...)
# Inspect all nodes.
i = my_app.control.inspect()
# Show the items that have an ETA or are scheduled for later processing
i.scheduled()
# Show tasks that are currently active.
i.active()
# Show tasks that have been claimed by workers
i.reserved()
ご希望に応じて