我试图获取 Celery 排队任务的等待时间。据我所知,我可以通过 Celery 工作人员发布的事件流来做到这一点。好奇的是,为什么队列任务中没有嵌入简单的时间戳?这与分布式系统设计有关吗?
注意: celery ==3.0.12
最佳答案
您不能依赖分布式系统中的物理墙时间,因此这样的字段不会很有用。
对于事件流,情况有所不同,因为任务启动
和任务成功
时间戳均来自同一时钟源。
也就是说,有时近似值会很有用,因此您可以添加此值 自己的信息:
add.apply_async((4, 4), headers={'time_sent': time.time()})
您可以访问任务中的消息 header (但请注意,这需要 Celery 3.1):
@app.task(bind=True)
def add(self, x, y):
print('Approximate queue time: {0}'.format(
time.time() - self.request.headers.get('time_sent', 0),
))
return x + y
关于python - 为什么 Celery 不将时间戳嵌入到排队消息中?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21108840/