AWS Elasticsearch - 按查询删除，如何查找任务 ID，以便在删除完成后可以继续执行代码，以及何时执行 wait_for _completion

Question

我正在使用 AWS Lambda 对 Elasticsearch 索引执行 delete_by_query，以便删除超过 7 天的所有内容。这是可行的，但我注意到文档的计数前后是相同的，所以如果我要在 Elasticsearch 中运行查询，在 delete_by_query 完成之前我可能无法获得正确的结果。

我找到了这篇文章（python 3.x - 删除的正确方法然后重新索引 ES 文档 - Stack Overflow），其中指出“最好将 wait_for_completion 设置为 False。在这种情况下，您将获得任务详细信息并能够跟踪任务进度。”首先，我还没有找到任何说明为什么会出现这种情况的信息，除非像那个示例那样删除需要 4 个小时。

我在此处找到了确定delete_by_query是否仍在这个精彩网站上运行的代码尝试过：

es_client.tasks(detailed=True,actions="*/delete/byquery")

但是，我收到的消息是 “TasksClient”对象不可调用。

我不完全确定这是否属实，或者我的语法是否不正确，因此这就是它不起作用的原因。如果我可以在控制台中使用curl 执行任务，那么我无法使用python 以编程方式查询任务是没有意义的。

如果将 wait_for_completion 设置为 False 不好，并且我无法使用 Python 进行查询，那么我如何以编程方式获取有关任务的任何信息或了解我是否可以继续进行分析查询或其他任何我想要的操作？想要做什么取决于这个任务正在完成吗？

Answer 1

好吧，我不完全确定你为什么会收到这个错误，所以我无法特别帮助你。但是，我注意到关于当 wait_for_completion 设置为 false 时如何从 delete_by_query 获取任务 id 的 python elasticsearch 文档不是很清楚，所以我将提供这个以防它有帮助。

from elasticsearch import Elasticsearch
    
es = Elasticsearch()

response = es.delete_by_query(index=someIndex, body=someQuery, wait_for_completion=False)

# get task id
print(response['task'])

希望有帮助！