专栏首页热爱ITPython学习笔记 - 02: 用Python Client连接ElasticSearch操作数据

Python学习笔记 - 02: 用Python Client连接ElasticSearch操作数据

Python Elasticsearch Client 是 ES 官方推荐的 python 客户端,这里以它为工具操作 elasticsearch

一、环境依赖 Python:3.6

ES依赖包:pyelasticsearch

ElasticSearch:6.5.4

操作系统:MacOS

二、准备数据 json文件

https://github.com/elastic/elasticsearch/blob/master/docs/src/test/resources/accounts.json?raw=true

三、包含模块 from elasticsearch import Elasticsearch #或者 import elasticsearch #调用的时候需要elasticsearch.Elasticsearch 四、连接ES es = Elasticsearch([{"host":"localhost","port":9200}]) 五、单一操作 查看集群状态

from elasticsearch import Elasticsearch es=Elasticsearch([{"host":"localhost","port":9200}]) print(es.cluster.state()) 查看集群健康度

from elasticsearch import Elasticsearch es=Elasticsearch([{"host":"localhost","port":9200}]) print(es.cluster.health()) 增加一条文档

from elasticsearch import Elasticsearch es = Elasticsearch([{"host":"localhost","port":9200}]) print(es.cluster.state()) b= {"name": 'lu', 'sex':'female', 'age': 10} es.index(index='bank', doc_type='typeName',body=b,id=None) print(es.cluster.state()) 删除一条文档

from elasticsearch import Elasticsearch es = Elasticsearch([{"host":"localhost","port":9200}]) es.delete(index='bank', doc_type='typeName', id='idValue') 修改一条文档

from elasticsearch import Elasticsearch es = Elasticsearch([{"host":"localhost","port":9200}]) es.update(index='bank', doc_type='typeName', id='idValue', body={待更新字段}) 查询一条文档

from elasticsearch import Elasticsearch es = Elasticsearch([{"host":"localhost","port":9200}]) find=es.get(index='bank', doc_type='typeName', id='idValue') print(find) 六、批量操作 从json文件中批量添加文档

from elasticsearch import Elasticsearch es = Elasticsearch([{"host":"localhost","port":9200}]) with open('./accounts.json','r',encoding='utf-8') as file:     s =file.read()     print(s)     es.bulk(index='bank',doc_type='typeName',body=s) 按条件删除文档

query = {'query': {'match': {'sex': 'famale'}}}# 删除性别为女性的所有文档 query = {'query': {'range': {'age': {'lt': 11}}}}# 删除年龄小于51的所有文档 es.delete_by_query(index='indexName', body=query, doc_type='typeName') 按条件查询文档

query = {'query': {'match_all': {}}}# 查找所有文档 query = {'query': {'term': {'name': 'jack'}}}# 查找名字叫做jack的所有文档 query = {'query': {'range': {'age': {'gt': 11}}}}# 查找年龄大于11的所有文档 allDoc = es.search(index='indexName', doc_type='typeName', body=query) print allDoc['hits']['hits'][0]# 返回第一个文档的内容 Python Elasticsearch Client 还提供了很多功能

参考文档

https://elasticsearch-py.readthedocs.io/en/master/api.html

https://www.elastic.co/guide/en/elasticsearch/reference/current/docs.html

(adsbygoogle = window.adsbygoogle || []).push({});

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 四种解决Nginx出现403 forbidden 报错的方法(转)

    我是在在本地用虚拟机中通过yum安装nginx的,安装一切正常,但是访问时报403,

    双面人
  • CentOS7安装配置PostgreSQL9.6 转

    PostgreSQL 9.6.3:https://www.postgresql.org/download/linux/RedHat/

    双面人
  • nginx+yii2

    双面人
  • nginx配置属性说明

    用户1220053
  • 前端-用 JS 写一个同 Excel 表现的智能填充算法

    在使用Excel的时候,发现它的“智能填充”功能非常有趣,能够智能地分析我当前的内容,然后准确预测出我期望得到的值。排除了AI的加成,发现这个功能其实也可以通过...

    grain先森
  • 爬虫如何抓取网页的动态加载数据-ajax加载

    本文讲的是不使用selenium插件模拟浏览器,如何获得网页上的动态加载数据。步骤如下: 一、找到正确的URL。二、填写URL对应的参数。三、参数转化为urll...

    震八方紫面昆仑侠
  • SRE之道:创造软件系统来维护系统运行

    大家都知道, 计算机软件系统离开人通常是无法自主运行的。那么,究竟应该如何去运维一个日趋复杂的大型分布式计算系统呢?雇佣系统管理员(sysadmin)运维复杂的...

    博文视点Broadview
  • SAP最佳业务实践:MM–转包(138)-6付款

    3.11 付款 3.11.1 F-53应付帐款 (158) 在此活动中过帐付款。 完成该业务情景的业务流程文档中描述的所有活动:使用此文档中主数据的应付帐...

    SAP最佳业务实践
  • Android原生与H5通信

      如今,混合开发似乎成为了主流。H5拥有跨平台的优势,却存在性能上的问题正好可以用搭建原生壳承载H5代码的方式去解决。   如何理解这种方式,就好像说And...

    饮水思源为名
  • 爬虫学习(三)

    When something is important enough, you do it even if the odds are not in your f...

    小闫同学啊

扫码关注云+社区

领取腾讯云代金券