我正在使用适用于 Python 的 Elasticsearch 6.1 API,并尝试从数据库中的每个文档(303 958 个文档)中读取某个值。
doc = {
'size' : 1000,
'query' : {
'match_all' : {}
}
}
samplesCount = 0
res = es.search(index="index", doc_type='data', body=doc, scroll='1m')
scrollId = res['_scroll_id']
scrollSize = res['hits']['total']
while scrollSize > 0 :
for x in range (0, len(res['hits']['hits']) - 1) :
name = res['hits']['hits'][x]['_source']['name']
samplesCount += 1
print(str(samplesCount) + '. ' + name)
scrollSize -= 1
res = es.scroll(scroll_id=scrollId, scroll='1m')
索引(samplesCount)在 303 654 处结束,似乎 es.scroll 没有为剩余文档返回任何结果(大约 300,小于滚动大小)。
让我好奇的是,它以 303 654 结尾……我希望是一个整数(1000 的倍数)。
有任何想法吗 ?
非常感谢您提供任何有用的提示。