python - 在 Celery 任务中获取 task_id

Question

这可能是一个愚蠢的问题，但它让我从 Ruby 背景中难过。

当我尝试打印时，我有一个看起来像这样的对象。

print celery.AsyncResult.task_id
>>><property object at 0x10c383838>

我原以为这里会打印 task_id 属性的实际值。如何获得实际值？

更新 1

@celery.task
def scan(host):
    print celery.AsyncResult.task_id
    cmd = 'ps -ef'
    cm = shlex.split(cmd)
    scan = subprocess.check_output(cm)
    return scan

最好的问候。

Answer 1

短篇小说，在函数 scan 中，使用 scan.request.id。

参见 http://docs.celeryproject.org/en/latest/userguide/tasks.html?highlight=request#task-request-info