python之elasticsearch查询

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

下载所需模块

python安装好的情况下,通过pip install elasticsearch进行es模块的安装

安装完成后通过pip list命中查询

导入模块

 from elasticsearch import  Elasticsearch

 #用于将数据封装成dataframe格式

 import pandas

连接es集群

 # 以列表的形式存放各节点的IP地址

 ip=["11.158.2.24","11.158.2.25","11.158.2.26"]

 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)