我使用Django-Celery +rabbitmq执行一些异步任务,我定义了一个队列'sendmail'来执行发送电子邮件任务,发送邮件由特定任务触发(这个任务有自己的队列),但现在我遇到了一个问题,之后具体任务完成,邮件有时一次发送,有时需要5-20分钟。我想知道是什么原因造成的。
调用 task.delay() 时,Django-celery 会将 taskname 和 param 作为消息打包到 rabbitmq。
我想知道消息什么时候到rabbitmq,但是使用web管理工具只能看到总消息,看不到每条消息的详细信息,尤其是消息到达的时间。Django-celery 日志只能看到从代理时间和执行任务时间得到的工作。我想知道所有相关的时间点以确定主要消耗的时间是哪一步。