Celery:如何从自定义状态中检索元数据

Question

自定义状态的示例显示可以存储元数据：http://docs.celeryproject.org/en/latest/userguide/tasks.html#custom-状态

我可以使用哪个API来检索与结果相关联的元数据？

Answer 1

文档没有明确说明如何从结果中获取元数据。使用AsyncResult.info.

>>> job = AsyncResult(job_id)
>>> print(job.info)
{'current': 2, 'total': 100}

Answer 2

给出的示例如下：

@app.task(bind=True)
def upload_files(self, filenames):
    for i, file in enumerate(filenames):
        self.update_state(state='PROGRESS',
            meta={'current': i, 'total': len(filenames)})

当你设置任务时，比如

task = upload_files.delay(['happy.txt', 'sad.txt', ...])

您可以通过任务访问元信息。结果

希望对有所帮助