23

检查当前正在运行的 Celery 任务会发现一个奇怪的time_start时间戳：

>> celery.app.control.inspect().active()
{u'celery@worker.hostname': [{u'acknowledged': True,
   u'args': u'(...,)',
   u'delivery_info': {u'exchange': u'celery',
    u'priority': 0,
    u'redelivered': None,
    u'routing_key': u'celery'},
   u'hostname': u'celery@worker.hostname',
   u'id': u'3d92fdfd-524e-4ba1-98cb-cf83af2ad8e9',
   u'kwargs': u'{}',
   u'name': u'task_name',
   u'time_start': 9636801.218162088,
   u'worker_pid': 7931}]}

该time_start属性将任务追溯到1970 年（那是在创建 Celery、Python 之前，而且我没有定制的 DeLorean）：

>> from datetime import datetime
>> datetime.fromtimestamp(9636801.218162088)
datetime.datetime(1970, 4, 22, 13, 53, 21, 218162)

我是否误解了time_task属性？我的 Celery 应用程序配置错误吗？

我在 Linux 上使用带有 Django 应用程序和 Redis 后端的 Celery 3.1.4。

任务由执行如下的工作人员运行：

./manage.py celery worker --loglevel=INFO --soft-time-limit=600 --logfile=/tmp/w1.log --pidfile=/tmp/w1.pid -n 'w1.%%h'
4

1 回答 1

33

我通过挖掘 Celery 和 Kombu 代码找到了自己问题的答案：time_start任务的属性由kombu.five.monotonic函数计算。（具有讽刺意味的是，kombu 代码还引用了另一个StackOverflow 问题以供参考）该函数返回的时间戳指的是clock_gettime系统调用计算的“单调”时间。

如clock_gettime 文档中所述，此单调时间表示“从某个未指定的起点开始”经过的时间。此函数的目的是确保时间单调增加，尽管其他时钟值发生变化。

因此，为了获得任务开始的真实日期时间，我们只需要将time_start属性与单调时钟的当前值进行比较：

>> from datetime import datetime
>> from time import time
>> import kombu.five
>> datetime.fromtimestamp(time() - (kombu.five.monotonic() - 9636801.218162088))
datetime.datetime(2013, 11, 20, 9, 55, 56, 193768)

编辑：time_start检查报告的属性不再是单调的：https ://github.com/celery/celery/pull/3684我只花了四年时间写了一个正确的拉取请求0:-)

于 2013-11-20T12:44:10.837 回答