芹菜.获取当前链的id

Question

基于当前任务的get-id。

我称之为连锁：

chain = (nice_task.s(a=1) |
         task2.s(a=2)).apply_async()

任务定义为：

@celery.task(bind=True)
def nice_task(self, a):
    print a
    print self.request.id  # None
    return a

如何获取链内任务的id？

我试着打开/关闭CELERY_ALWAYS_EAGER，但没有效果。

UPD而且self.request有空的context。

Answer 1

调用链将调用链中的任务，并返回链中最后一个任务的结果。

当你调用像这样的链时

chain = (nice_task.s(a=1) | task2.s(a=2)).apply_async()

则返回CCD_ 4的结果。您可以通过检查chain.info 来验证这一点

In [25]: chain.info
Out[25]: 'task2'
In [26]: chain.id
Out[26]: 'bec26eff-2dfe-4203-aed2-a122d908c905'

要访问上一个任务，您需要使用.parent属性。chain.parent为您提供上一个任务，您可以从.id获取id。

In [27]: chain.parent
Out[27]: <AsyncResult: 242d338b-35fe-4f16-be07-36d0d8f2bb53>
In [28]: chain.parent.info
Out[28]: 'task1'
In [29]: chain.parent.id
Out[29]: '242d338b-35fe-4f16-be07-36d0d8f2bb53'