如何解决等同于在Elasticsearch中恢复搜索和滚动的操作
可以说,我在索引中有1000 documents
,并且我可以一次使用fetch 20 docs
来search and scroll
,直到基于iteration_count
的最后一个文档或更早的文档为止
较新的数据(say 500)
可能会及时插入到同一索引中,但是我希望从上次停止的位置搜索和滚动文档。我碰到了search_after
,但无法与我想像的滚动条一起使用。
有没有办法恢复搜索和滚动?
#search and scroll in batches of 20
index = "demo"
batch_size = 20
scroll_interval = "5m"
#to ignore the newer records inserted,if any,after the first search query
count = es.count(index='demo',body={})['count']
iteration_count = count//batch_size
data = []
result = es.search(
index=index,body={},size=batch_size,scroll=scroll_interval)
for hit in result["hits"]["hits"]:
data.append(hit['_source'])
scroll_id = result['_scroll_id']
scroll_size = result["hits"]["total"]["value"]
i = 0
while((scroll_size > 0) & (i < iteration_count)):
print("\n\n","Scrolling ({})...".format(i),",scroll_size,i,iteration_count)
result = es.scroll(scroll_id=scroll_id,scroll="5m")
scroll_id = result["_scroll_id"]
scroll_size = len(result['hits']['hits'])
for hit in result["hits"]["hits"]:
data.append(hit['_source'],ignore_index=True)
i += 1
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。