1 ES資料讀寫流程¶

ES中，每個索引都將被劃分為若干分片，每個分片可以有多個副本。這些副本共同組成複製組，複製組中的分片在新增或刪除文件時必須保持同步，否則，從一個副本中讀取的資料將與從另一個副本讀取的結果有差異。保持複製組中分片資料同步以及從它們中讀取的過程稱為資料複製模型。

ES的資料複製模型基於主備份模型，這種模型使用複製組的一個分片作為主分片，複製組中其他分片作為副本分片。主分片是所有索引操作的主要入口點，負責驗證操作的有效性。一旦主分片通過操作驗證，主資料庫還負責將該操作複製到其他副本。

1.1 資料寫入流程¶

ES中的每個索引操作首先解析到對應的複製組中，通常基於文件 ID，確定複製組後，操作將在內部轉發到複製組的當前主分片。主分片介紹到操作請求後，將對操作請求進行驗證再轉發到其他副本中。

主分片遵循以下基本流：

（1）驗證傳入操作，並在結構無效時拒絕它（例如：給定值與欄位型別不匹配）

（2）在本地執行操作，即索引或刪除相關文件。這也需要驗證欄位的內容，並根據需要拒絕（例如：關鍵字值太長）。

（3）將操作轉發到當前同步副本集的每個副本。如果有多個副本，則並行執行。

（4）一旦所有副本成功執行了該操作並響應了主副本，主副本將確認成功完成對客戶端的請求。

1.2 資料讀取流程¶

ES中的讀取可以是非常輕量級的按 ID 查詢，也可以是具有複雜聚合的重搜尋請求。ES所採用的主備份模型的一大亮點就是它使所有分片副本保持同步，因此，單個同步副本足以提供讀取請求。

當節點收到讀取請求時，該節點負責將該請求轉發到包含相關資料的分片節點、整理響應以及響應客戶端。基本流程如下：

（1）將讀取請求解析為相關分片。請注意，由於大多數搜尋將傳送到一個或多個索引，因此它們通常需要從多個分片讀取，每個分片表示資料的不同子集。

（2）從分片複製組中選擇每個相關分片的活動副本。這可以是主分片，也可以是副本分片。預設情況下，彈性搜尋將只是在分片副本之間迴圈。

（3）將各分片讀取請求傳送到所選副本分片。

（4）合併結果並做出響應。注意，在通過 ID 查詢的情況下，只有一個分片是相關的，可以跳過此步驟。

2 文件寫入操作¶

使用下列API可以將一個JSON文件新增到指定的索引中，如果在指定索引中已存在該文件，那麼這一操作將會更新文件，並使文件的version自增1。

PUT /<target>/_doc/<_id>

POST /<target>/_doc/

PUT /<target>/_create/<_id>

POST /<target>/_create/<_id>

其中，target是一個必填引數，指的是目標索引，如果目標索引不存在，那麼將會自動建立一個索引；_id是一個可選引數，指的是為文件指定的唯一標識，如果省略_id引數的話，將會和POST /<target>/_doc/API一樣，自動為文件設定一個id。

• 唯一標識（_id）

上圖例項中，users索引原本是不存在的，建立文件時，將自動建立索引，另外，由於建立文件時，並未指定_id，ES將自動為文件設定一個_id，注意，_id是ES對文件的唯一標識，與文件內容中的id是不一樣的。如下所示，新增文件時指定_id引數：

相關推薦