python - 如何获取下一个 celery task_id或如何从任务本身(Flask)获取任务id或如何为任务设置自定义id？

Question

我的 flask 应用程序中有一些 celery :

# Initialize Celery
celery = Celery("DockerApp", broker=config['CELERY_BROKER_URL'])
celery.conf.update(config)

我有任务:

@celery.task
def some_task(data):
    some_task.request.id #not working
    #my task code goes here

我需要任务本身内该任务的 id，或者我需要自己设置该 id。有人可以帮忙吗？

当我调用任务时:

result = some_task.delay(data)
print result.id #this is correct

这给了我正确的结果。

Answer 1

您还可以通过以下方式访问任务内部的任务请求:

@celery.task(bind=True)
def some_task(self, data):
    print self.request.id