国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 操作系統(tǒng) > 正文

Elastic search問題筆記: scroll查詢數據

2024-06-28 16:05:27
字體:
來源:轉載
供稿:網友

elastic search在普通方式查詢時會返回記錄總數以及開頭的若干條,即便指定from和相應的長度size也有總數限制。根據文檔介紹,這時需要通過scroll分頁查詢,在初次查詢時指定改方式,之后不斷的調用scroll方法針對同_scroll_id會得到后續(xù)數據。就像通過一個固定的游標以及指定的窗口大小來不斷滾動獲得新的數據。

from elasticsearch import Elasticsearchif __name__ == '__main__': es =elasticSearch('elk.dev') page = es.search(index='PRod_nginx_20170211', _source=['localtime', 'request'], scroll='2m', size=10) sid = page['_scroll_id'] page_size = page['hits']['total'] for i in range(page_size//10 + 1): res = es.scroll(scroll_id = sid) for doc in res['hits']['hits']: print(doc['_source']['localtime'] + '---->' + doc['_source']['request']) print("===================================/n")

結果: 腳本執(zhí)行總是在刷出30條記錄后報錯。”elasticsearch.exceptions.NotFoundError: TransportError(404, ‘search_phase_execution_exception’, ‘No search context found for id [874876]’)” pub單步調試時,也是在30條后,再次執(zhí)行res = es.scroll(scroll_id=sid)時報404錯誤。(未解)

curl方式測試對比

在群里以及文檔中介紹的提示,scroll查詢時也可能會改變scroll_id值,所以每次查詢時需要使用最新的scroll_id。但測試發(fā)現從elasticsearch.scroll方法返回的結果中并沒有scroll_id值。 換另一種調用方式,在kibana中直接GET:

## 先初次查詢指定scroll GET /prod_nginx_20170211/_search?scroll=1m&size=100{ "_source": ["localtime", "request"]}## 調用scrollGET /_search/scroll{ "scroll": "1m", "scroll_id": "DnF1ZXJ5VGhlbkZldGNoAwAAAAAADaFSFlh6SG0xQmYxU2JXNm1sLXRZNFFCZ1EAAAAAAA2hVBZYekhtMUJmMVNiVzZtbC10WTRRQmdRAAAAAAANoVMWWHpIbTFCZjFTYlc2bWwtdFk0UUJnUQ=="}## 后續(xù)查詢時,使用返回結果中最新的scroll_id更新上面的再次查詢(PS:20170213)
發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 青岛市| 太仓市| 榆树市| 枣强县| 开平市| 德钦县| 博爱县| 吉首市| 蒲江县| 张家界市| 南溪县| 融水| 平阴县| 辽中县| 邹平县| 津市市| 平定县| 怀仁县| 西青区| 固安县| 孟津县| 保定市| 石狮市| 富蕴县| 林周县| 原阳县| 扎鲁特旗| 昌宁县| 秭归县| 新乡县| 鄂伦春自治旗| 哈尔滨市| 饶河县| 临桂县| 泰兴市| 陇川县| 葵青区| 故城县| 吴堡县| 佳木斯市| 沈丘县|