0、準備開啟數據庫

① 關閉Linux防火墻，這個很重要，否則API總是報錯連不上。

# 查看防火墻狀態 firewall-cmd --state# 關閉防護墻 systemctl stop firewalld.service# 開啟防火墻 systemctl start firewalld.service# 重啟防火墻 systemctl restart firewalld.service# 禁止firewalld開機啟動 systemctl disable firewalld.service

② 啟動elasticsearch

bin/elasticsearch

③ 啟動Kibana

bin/kibana

1、使用conda或者pip安裝elasticsearch 6.1.1

# 使用conda conda install elasticsearch=6.1.1#使用pip pip install elasticsearch==6.1.1

2、主要的Python代碼

# -*- coding: utf-8 -*- from elasticsearch import Elasticsearchif __name__ == '__main__':es = Elasticsearch(['192.168.1.211'], http_auth=('elastic', '5tgbhu8'), port=9200)index = "my_index"dtype = "my_type"mappings = \{dtype: {"include_in_all": False,"properties": {"A": {"type": "nested","properties": {"A1": {"type": "keyword"},"A2": {"type": "long"}}},"B": {"type": "nested","properties": {"B1": {"type": "keyword"},"B2": {"type": "long"}}}}}}body = {"ThemeCount": [{"A1": "file","A2": 35},{"A1": "root","A2": 45}],"B": [{"B1": "work","B2": 56},{"B1": "etc","B2": 88}]}if es.indices.exists(index=index):es.indices.delete(index=index)es.indices.create(index=index)# 設置mappinges.indices.put_mapping(doc_type=dtype, body=mappings, index=index)es.index(index=index, doc_type=dtype, body=body)

3、使用Kibana查看結果

# 在瀏覽器中打開 http://192.168.1.211:5601# Dev tools GET /my_index/_search 數據入到es庫中

?

?

?

總結

以上是生活随笔為你收集整理的（二）ElasticSearch6.1.1 Python API的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。