对当前运行的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上使用Celery 3.1.4,带有Django应用程序和Redis后端。
任务由工作人员运行,其执行方式如下:
./manage.py celery worker --loglevel=INFO --soft-time-limit=600 --logfile=/tmp/w1.log --pidfile=/tmp/w1.pid -n 'w1.%%h'
我通过挖掘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)
EDIT:检查报告的time_start
属性不再是单调的:https://github.com/celery/celery/pull/3684我只花了四年时间就写出了一个正确的拉取请求0:-)