python之elasticsearch查詢

下載所需模塊

python安裝好的情況下,通過pip install elasticsearch進行es模塊的安裝

安裝完成后通過pip list命中查詢

 

導入模塊

from elasticsearch import Elasticsearch 2 #用於將數據封裝成dataframe格式
import pandas

 

連接es集群

# 以列表的形式存放各節點的IP地址
ip=["11.158.2.24","11.158.2.25","11.158.2.26"] 3 es=Elasticsearch(ip)

 

查詢操作

#字段形式設置es查詢body,根據相應的索引進行查詢
b={ "query": {"match": {"email": "00011100001" }}}

data=es.search(index="xxx-2020-03-12",doc_type='angelLog',body=b)

#打印查詢結果

data1=data['test001']['test001'][0]['_source']

print(data1)

 

 

 

封裝結果

#將查詢報文封裝成dataframe格式,可用於數據解析
df = pandas.DataFrame(data,index=[0])
print(type(df))
print(df)