为什么 Celery 没有将时间戳嵌入到排队的消息中

Question

我试图获取芹菜排队任务的等待时间。据我所知，我可以通过芹菜工人发布的事件流来做到这一点。出于好奇，为什么排队的任务中没有嵌入简单的时间戳？这与分布式系统设计有关吗？

注意：芹菜==3.0.12

Answer 1

在分布式系统中，您不能依赖物理墙时间，因此这样的字段不是很有用。

对于事件流，这是不同的，因为task-started和task-succeeded时间戳都来自同一时钟源。

也就是说，有时近似值可能很有用，因此您可以添加此值自己提供信息：

add.apply_async((4, 4), headers={'time_sent': time.time()})

您可以访问任务中的消息标头（但请注意，这需要 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