我正在使用 redis 运行 celerly 2.5.1。我想为在 celerymon 或 celeryev 中显示的 celery 任务获取相同的任务信息。那是:
celeryev 2.5.1
│ │ UUID 工人任务时间状态
│ │ 59587fe7-b83f-4cf3-8343-6abdfbc016e7 watson-thinkpad app.task 18:14:03 收到
但是,我从文档和各种帖子中只看到两条路径。
result = task.AsyncResult(task_id)
result.get()
无论任务的回调返回什么,它都能让我得到,而不是 celeryev 提供的更多信息行。
然后是 celerymon 中使用的方法,它涉及设置消费者、接收者和单独的线程来处理龙卷风过程中来自 celery 的信息。
但是,我正在寻找的是像前者一样的简单呼叫表格,但后者提供了详细信息。我不需要像在celeryev 中那样动态刷新信息,只显示一次。
是否可以在不启动单独的事件循环或线程的情况下使用现有的 celery 2.5 API for python 来做到这一点?如果可能的话,我已经受够了那些我宁愿没有额外的复杂性的人。
谢谢。