Advertisement

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)

还没有任何评论哟~