基于python操作ES实例详解

Rhoda ·

更新时间:2024-11-15

· 804 次阅读

这篇文章主要介绍了基于python操作ES实例详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

安装


pip install elasticsearch5 # 安装对应版本的模块

创建ES对象


from elasticsearch5 import Elasticsearch 
# elasticsearch集群服务器的地址
ES = [
  '127.0.0.1:9200'
]
# 创建elasticsearch客户端
es = Elasticsearch(
  ES,
  # 启动前嗅探es集群服务器
  sniff_on_start=True,
  # es集群服务器结点连接异常时是否刷新es节点信息
  sniff_on_connection_fail=True,
  # 每60秒刷新节点信息
  sniffer_timeout=60
)

搜索数据


query = {
  'query': {
    'bool': {
      'must': [
        {'match': {'_all': 'python web'}}
      ],
      'filter': [
        {'term': {'status': 2}}
      ]
    }
  }
}
ret = es.search(index='articles', doc_type='article', body=query)

添加数据


doc = {
     'article_id': article.id,
     'user_id': article.user_id,
     'title': article.title
   }
es.index(index='articles', doc_type='article', body=doc, id=article.id)

您可能感兴趣的文章:python使用 request 发送表单数据操作示例Python mutiprocessing多线程池pool操作示例Python编程在flask中模拟进行Restful的CRUD操作python3+requests接口自动化session操作方法Python读取properties配置文件操作示例Python中用psycopg2模块操作PostgreSQL方法使用Python对Access读写操作Python操作Access数据库基本步骤分析python进程类subprocess的一些操作方法例子Python使用PyGreSQL操作PostgreSQL数据库教程

Python

1024 个赞