python处理es数据
发布时间
阅读量:
阅读量
时光荏苒,踏入职场已逾半年,期间虽有所收获,但亦深刻体会到自身能力的不足,意识到仍需不断学习与提升。近期在项目实践中,需借助Python实现对ES数据的读写操作,尝试了网络上多种方法,却发现部分方法已不再适用,或在执行过程中出现错误,耗费了不少时间方才顺利完成。现将相关经验整理记录,既便于自我回顾,也可为其他读者提供参考。
1)首先需安装对应的ES处理库;
pip install elasticsearch
2)实现ES数据的读取操作;
from elasticsearch import Elasticsearch, helpers
def read_es(host, port,index, query=""):
url = {"host": host, "port": port, "timeout": 1500}
es = Elasticsearch([url])
if es.ping():
print("Successfully connect!")
else:
print("Failed.....")
exit()
if query == "": #query为es的搜索条件
query = {
"q
全部评论 (0)
还没有任何评论哟~
