如何查看任务是否已完成?

问题描述 投票:0回答:1

我保存了以下更新查询:

>>> self.es.update_by_query(body=body, doc_type='_doc', index='trackingesthistory', request_timeout=30, wait_for_completion=False)

{u'task': u'dEy4zO6jQuqs4wRV61t3Bw:8846674'}

现在,我将如何看待该任务是否已完成?这是我尝试过的:

>>> elasticsearch.client.TasksClient.get('dEy4zO6jQuqs4wRV61t3Bw:8846674')

回溯(最近一次调用最后一次):TypeError中的文件“”,第1行:必须使用TasksClient实例作为第一个参数调用未绑定方法get()(改为使用str实例)

在python中获取任务状态的正确方法是什么?

python elasticsearch
1个回答
0
投票

您需要将ElasticSearch客户端对象传递给它,如下所示:

tasks = elasticsearch.client.TasksClient(self.es)
tasks.get('dEy4zO6jQuqs4wRV61t3Bw:8846674')

然后,这将为您提供所需的信息。

© www.soinside.com 2019 - 2024. All rights reserved.