Celery - 获取当前任务的任务ID

Question

如何从任务中获取任务的 task_id 值？这是我的代码：

from celery.decorators import task
from django.core.cache import cache

@task
def do_job(path):
    "Performs an operation on a file"

    # ... Code to perform the operation ...

    cache.set(current_task_id, operation_results)

这个想法是，当我创建任务的新实例时，我从任务对象中检索 task_id 。然后我使用任务 ID 来确定任务是否已完成。我不想通过path值跟踪任务，因为文件在任务完成后被“清理”，并且可能存在也可能不存在。

在上面的例子中，我如何获取current_task_id的值？

Answer 1

更新：使用 Balthazar 对 Celery 3.1+ 的答案，

@task(bind=True)
def do_job(self, path):
   cache.set(self.request.id, operation_results)

请随意投票支持他的答案。

旧答案：

从 Celery 2.2.0 开始，与当前执行任务相关的信息被保存到 task.request （称为“上下文”）。因此，您应该从此上下文中获取任务 ID（而不是从关键字参数中获取，该参数已弃用）：

@task
def do_job(path):
    cache.set(do_job.request.id, operation_results)

所有可用字段的列表记录在此处：
http://celery.readthedocs.org/en/latest /userguide/tasks.html?highlight=requestcontext#context

Answer 2

从 celery 3.1 开始，您可以使用 bind 装饰器参数，并可以访问当前请求：

@task(bind=True)
def do_job(self, path):
    cache.set(self.request.id, operation_results)

Answer 3

如果任务接受，Celery 确实会设置一些默认关键字参数。
（您可以通过使用 **kwargs 接受它们，或专门列出它们）

@task
def do_job(path, task_id=None):
    cache.set(task_id, operation_results)

默认关键字参数的列表记录在此处：
http://ask.github.com/celery/userguide/tasks .html#默认关键字参数