原文鏈接

文檔：http://elasticsearch-py.readthedocs.io/en/master/
Elasticsearch官方API文檔：
https://www.elastic.co/guide/en/elasticsearch/reference/current/search.html
兩種方式現實Elasticsearch API操作
方式一：安裝elasticsearch模塊，通過它操作Elasticsearch，代碼示例如下

from elasticsearch import Elasticsearchclass ElasticSearchClass(object):def __init__(self, host, port, user, passwrod):self.host = hostself.port = portself.user = userself.password = passwrodself.connect()def connect(self):self.es = Elasticsearch(hosts=[{'host': self.host, 'port': self.port}],http_auth=(self.user, self.password ))def count(self, indexname):""":param indexname::return: 統計index總數"""return self.es.count(index=indexname)def delete(self, indexname, doc_type, id):""":param indexname::param doc_type::param id::return: 刪除index中具體的一條"""self.es.delete(index=indexname, doc_type=doc_type, id=id)def get(self, indexname, id):return self.es.get(index=indexname, id=id)def search(self, indexname, size=10):try:return self.es.search(index=indexname, size=size, sort="@timestamp:desc")except Exception as err:print(err)

方式二：安裝requests模塊，通過GET、POST方式操作Elasticsearch

class RequestsElasticSearchClass(object):def __init__(self, host, port, user, passwrod):self.url = 'http://' + host + ':' + str(port)basicpwd = base64.b64encode((user + ':' + passwrod).encode('UTF-8'))self.headers = {"User-Agent": "shhnwangjian","Content-Type": "application/json","Authorization": "Basic {}".format(basicpwd.decode('utf-8'))}def search(self, indexname, size=10):gettdata = {"sort": "@timestamp:desc","size": size}url = self.url + '/' + indexname + '/_search'ret = requests.get(url, headers=self.headers, timeout=10, params=gettdata)print(ret.text)

總結

以上是生活随笔為你收集整理的python elasticsearch的全部內容，希望文章能夠幫你解決所遇到的問題。

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