国产探花免费观看_亚洲丰满少妇自慰呻吟_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ā)表
主站蜘蛛池模板: 黄龙县| 开远市| 包头市| 定南县| 广饶县| 读书| 抚州市| 黔西| 新乡市| 临桂县| 黄平县| 牡丹江市| 阿克苏市| 康马县| 旺苍县| 九江市| 正蓝旗| 岳池县| 石台县| 庆元县| 平顶山市| 临桂县| 马边| 日喀则市| 阳江市| 黄龙县| 称多县| 拉孜县| 鄢陵县| 方城县| 茶陵县| 柳州市| 蕲春县| 基隆市| 韩城市| 南宁市| 镇安县| 开远市| 北碚区| 柳河县| 扎鲁特旗|