如何安裝Elasticsearch py客戶端庫及使用方法

今天就跟大家聊聊有關如何安裝Elasticsearch py客戶端庫及使用方法，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

一、介紹

elasticsearch-py是一個官方提供的low-level的elasticsearch python客戶端庫。為什么說它是一個low-level的客戶端庫呢？因為它只是對elasticsearch的rest API接口做了一層簡單的封裝，因此提供了最大的靈活性，但是于此同時使用起來就不是太方便。

二、安裝

不同的elasticsearch版本要求不同的客戶端版本，所以安裝的時候需要根據你的elasticsearch來決定，下面是一個簡單的參考：

# Elasticsearch 6.x
elasticsearch>=6.0.0,<7.0.0
# Elasticsearch 5.x
elasticsearch>=5.0.0,<6.0.0
# Elasticsearch 2.x
elasticsearch>=2.0.0,<3.0.0

在兼容的大的版本號下盡量選擇最新的版本。

pip install elasticsearch

三、API

3.1 API文檔

所有API都盡可能緊密的映射原始的rest API。

3.1.1 全局選項

某些被客戶端添加的參數可以使用在所有的API上。

1.ignore

被用戶忽略某些http錯誤狀態碼。

from elasticsearch import Elasticsearch
es = Elasticsearch()

# ignore 400 cause by IndexAlreadyExistsException when creating an index
es.indices.create(index='test-index', ignore=400)

# ignore 404 and 400
es.indices.delete(index='test-index', ignore=[400, 404])

2.timeout

被用于設置超時時間。

# only wait for 1 second, regardless of the client's default
es.cluster.health(wait_for_status='yellow', request_timeout=1)

3.filter_path

被用于過濾返回值。

es.search(index='test-index', filter_path=['hits.hits._id', 'hits.hits._type'])

3.1.2 Elasticsearch

Elasticsearch是一個low-level客戶端，提供了一個從python到es rest端點的直接映射。這個實例擁有屬性cat、cluster、indices、ingest、nodes、snapshot和tasks，通過他們可以訪問CatClient、ClusterClient、IndicesClient、IngestClient、NodesClient、SnapshotClient和TasksClient的實例。

elasticsearch類包含了操作elasticsearch許多常用方法，例如：get、mget、search、index、bulk、create、delete等，這些方法的具體用法，可以參考elasticsearch-py的官方文檔。

在執行以上方法之前，首先需要獲得一個elasticsearch的實例，而獲取這個實例有兩個方法，一個是給elasticsearch的初始化函數傳遞一個connection class實例，另一個是給elasticsearch的初始化函數傳遞要連接的node的host和port，其實最終這些host、port還是被傳遞給了connection class。

# create connection to localhost using the ThriftConnection
es = Elasticsearch(connection_class=ThriftConnection)

# connect to localhost directly and another node using SSL on port 443
# and an url_prefix. Note that ``port`` needs to be an int.
es = Elasticsearch([
  {'host': 'localhost'},
  {'host': 'othernode', 'port': 443, 'url_prefix': 'es', 'use_ssl': True},
])

3.1.3 Indices

indices用于操作、查詢關于索引的信息，或者可以說是操作、查詢索引相關的元數據。

3.1.4 Ingest

ingest是一個插件，用于豐富插入數據的插入。

3.1.5 Cluster

cluster用于獲取和集群相關的信息，例如：集群的健康狀態、settings等。

3.1.6 Nodes

nodes用于獲取和節點相關的信息。

3.1.7 Cat

cat可以用來獲取別名、分片信息、文檔數量等信息。

3.1.8 Snapshot

snapshot用于管理快照。

3.1.9 Tasks

tasks是用于任務管理的，官方文檔上提示該task是新特性，未來可能會改變，所以要注意。

3.2 X-Pack APIs

X-Pack是Elastic Stack擴展，它將安全性，警報，監視，報告和圖形功能捆綁到一個易于安裝的程序包中。

• 3.2.1 Info
• 3.2.2 Graph Explore
• 3.3.3 Licensing API
• 3.3.4 Machine Learning
• 3.3.5 Security APIS
• 3.3.6 Watcher APIS
• 3.3.7 Migration APIS
   

3.3 異常

這一節展示了使用elasticsearch-py時可能拋出的異常。

3.4 連接層API

connection是負責與集群連接的類。

3.4.1 Transport

transport封裝與邏輯相關的傳輸。處理各個連接的實例化，并創建一個連接池來保存它們。

3.4.2 Connection Pool

connection pool是一個連接池，用于管理連接。

3.4.3 Connection Selector

connection selector是一個連接選擇器，它最好的一個例子是zone-aware選擇，可以自動選擇本地連接，只有當本地node都無法連接是才會去選擇連接其他node。

3.4.4 Urllib3HttpConnection

默認connection class。

3.5 傳輸類

傳輸模塊列出了可以被當做elasticsearch初始化參數connection_class的connection class。

3.5.1 Connection

connection負責管理與elasticsearch節點的連接。

3.5.2 Urllib3HttpConnection

基于urllib的connection class，是默認connection class。

3.5.3 RequestsHttpConnection

基于requests的connection class，除非要使用requests相關的高級特性，否則建議不要使用該類。

3.6 helpers

helpers是一個簡單的輔助函數的集合，這些函數抽象了一些細節或原始API。

3.6.1 bulk helpers

bulk API的特定格式要求導致直接使用它們會非常復雜，因此這里提供了幾個bulk API的helper函數，具體使用方法可以參考elasticsearch-py的官方文檔。

3.6.2 scan

scan是對scroll API的簡單抽象。

3.6.3 reindex

reindex用于將可能滿足給定查詢的一個索引中的所有文檔重新索引到另一個索引

看完上述內容，你們對如何安裝Elasticsearch py客戶端庫及使用方法有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。