Python *** 作Elasticsearch Api

概述一.环境准备:Python3.8Elasticsearch7.5VirtaulBox虚拟机客户端CentOs7参考文档:https://elasticsearch-py.readthedocs.io/en/v7.12.1ransports.html二.连接Es安装依赖包:pipinstallelasticsearch连接es方法:#-*-coding=utf8-*-fromelasticsearchim 一. 环境准备:

Python 3.8
Elasticsearch 7.5
VirtaulBox 虚拟机客户端CentOs7
参考文档: https://elasticsearch-py.readthedocs.io/en/v7.12.1/transports.HTML

二. 连接Es安装依赖包:pip install elasticsearch连接es 方法:

# -*- Coding=utf8 -*-from elasticsearch import Elasticsearchimport Jsones = Elasticsearch(hosts="192.168.0.102", port=9200)

三.API详解
第一种: 获取索引信息
(a) 方法: cat
(b) 代码示例:es.cat.indices(index=None)
© 代码:

# index= None:表示查询所有的索引, 如果传入单个索引名表示查询单个索引信息print(es.cat.indices(index=None))# print(es.cat.indices(index='bark'))   # yellow open bark NZYr9-8JsM-uoYvIHiYe6g 1 1 150 0 55.4kb 55.4kb  

结果:

green  open .kibana_7.12.1_001              OJwFwVauSTWcL_RI7PLdZA 1 0  68   10   2.1mb   2.1mbgreen  open .apm-custom-link                ZiM3n3fWR0icqm3FO9RKhg 1 0   0    0    208b    208byellow open bark                            NZYr9-8JsM-uoYvIHiYe6g 1 1 150    0  55.4kb  55.4kbgreen  open .apm-agent-configuration        Z9NrQV5dRuuO84bPYEUQyA 1 0   0    0    208b    208bgreen  open .kibana_task_manager_7.12.1_001 HD8P3_JsRmWKsVhzZyf26g 1 0   9 1470 221.9kb 221.9kbgreen  open .kibana-event-log-7.12.1-000001 OcqhJ8bcTluGbtcnglVVUw 1 0   2    0    11kb    11kbgreen  open .kibana-event-log-7.12.1-000002 9aaYdlYpSnK3Ih_8qWgfDA 1 0   1    0   5.6kb   5.6kbgreen  open .tasks                          KknWSFFbRxubG5TzdX-pzg 1 0   2    0   7.8kb   7.8kbyellow open customer                        BskrxEfmTt6wEjfNVASyDg 1 1   1    0   3.8kb   3.8kb

第二种:获取索引信息

获取索引信息
(a) 方法: indices.get_mapPing
(b) 代码示例: es.indices.get_mapPing(index=None,doc_type=None,params=None)
© 代码

# -*- Coding=utf8 -*-from elasticsearch import Elasticsearchimport Json#  连接es服务端,配置端口es = Elasticsearch(hosts="192.168.0.102", port=9200)#  获取所以方法:#	参数为: 获取哪个索引就获取哪个索引的信息, 不传代码获取全部的索引信息.get= es.indices.get_mapPing(index=None,doc_type=None,params=None)#   获取指定的索引.#get= es.indices.get_mapPing(index="bark",doc_type=None,params=None)#  返回结果是dict格式,通过Json转成JsON格式dumps = Json.dumps(get)print(dumps)

© 返回的结果,与postman调用查询所有的索引的结果一致

删除索引:
方法: es.indices.delete(index=indexname)
代码:

delete= es.indices.delete(index='test01')print(delete)

返回结果:
{'ackNowledged': True}

总结

以上是内存溢出为你收集整理的Python *** 作Elasticsearch Api全部内容，希望文章能够帮你解决Python *** 作Elasticsearch Api所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。