<kbd id="afajh"><form id="afajh"></form></kbd>
<strong id="afajh"><dl id="afajh"></dl></strong>
    <del id="afajh"><form id="afajh"></form></del>
        1. <th id="afajh"><progress id="afajh"></progress></th>
          <b id="afajh"><abbr id="afajh"></abbr></b>
          <th id="afajh"><progress id="afajh"></progress></th>

          用圖講解 ElasticSearch 搜索原理,你就明白了!

          共 3479字,需瀏覽 7分鐘

           ·

          2020-09-22 20:44

          先自上而下,后自底向上的介紹ElasticSearch的底層工作原理,試圖回答以下問題:

          • 為什么我的搜索?foo-bar?無法匹配?_foo-bar_??

          • 為什么增加更多的文件會壓縮索引(Index)?

          • 為什么ElasticSearch占用很多內(nèi)存?

          圖解ElasticSearch

          云上的集群
          集群里的盒子

          云里面的每個白色正方形的盒子代表一個節(jié)點——Node。

          節(jié)點之間

          在一個或者多個節(jié)點直接,多個綠色小方塊組合在一起形成一個ElasticSearch的索引。

          索引里的小方塊

          在一個索引下,分布在多個節(jié)點里的綠色小方塊稱為分片——Shard。

          Shard=Lucene Index

          一個ElasticSearch的Shard本質(zhì)上是一個Lucene Index。

          Lucene是一個Full Text搜索庫(也有很多其他形式的搜索庫),ElasticSearch是建立在Lucene之上的。接下來的故事要說的大部分內(nèi)容實際上是ElasticSearch如何基于Lucene工作的。

          圖解Lucene

          Mini索引——segment

          在Lucene里面有很多小的segment,我們可以把它們看成Lucene內(nèi)部的mini-index。

          Segment內(nèi)部

          有著許多數(shù)據(jù)結(jié)構(gòu)

          • Inverted Index

          • Stored Fields

          • Document Values

          • Cache

          最最重要的Inverted Index

          Inverted Index主要包括兩部分:

          1. 一個有序的數(shù)據(jù)字典Dictionary(包括單詞Term和它出現(xiàn)的頻率)。

          2. 與單詞Term對應(yīng)的Postings(即存在這個單詞的文件)。

          當(dāng)我們搜索的時候,首先將搜索的內(nèi)容分解,然后在字典里找到對應(yīng)Term,從而查找到與搜索相關(guān)的文件內(nèi)容。

          查詢“the fury”
          自動補全(AutoCompletion-Prefix)

          如果想要查找以字母“c”開頭的字母,可以簡單的通過二分查找(Binary Search)在Inverted
          Index表中找到例如“choice”、“coming”這樣的詞(Term)。

          昂貴的查找

          如果想要查找所有包含“our”字母的單詞,那么系統(tǒng)會掃描整個Inverted Index,這是非常昂貴的。


          在此種情況下,如果想要做優(yōu)化,那么我們面對的問題是如何生成合適的Term。


          問題的轉(zhuǎn)化

          對于以上諸如此類的問題,我們可能會有幾種可行的解決方案:

          • suffix -> xiffus
            如果我們想以后綴作為搜索條件,可以為Term做反向處理。

          • (60.6384, 6.5017) -> u4u8gyykk
            對于GEO位置信息,可以將它轉(zhuǎn)換為GEO Hash。

          • 123 -> {1-hundreds, 12-tens, 123}

          對于簡單的數(shù)字,可以為它生成多重形式的Term。

          解決拼寫錯誤

          一個 ?Python庫

          https://pypi.python.org/pypi/misspellings

          為單詞生成了一個包含錯誤拼寫信息的樹形狀態(tài)機,解決拼寫錯誤的問題。

          Stored Field字段查找

          當(dāng)我們想要查找包含某個特定標(biāo)題內(nèi)容的文件時,Inverted Index就不能很好的解決這個問題,所以Lucene提供了另外一種數(shù)據(jù)結(jié)構(gòu)Stored
          Fields來解決這個問題。本質(zhì)上,Stored Fields是一個簡單的鍵值對key-
          value。默認情況下,ElasticSearch會存儲整個文件的JSON source。

          Document Values為了排序,聚合

          即使這樣,我們發(fā)現(xiàn)以上結(jié)構(gòu)仍然無法解決諸如:排序、聚合、facet,因為我們可能會要讀取大量不需要的信息。
          所以,另一種數(shù)據(jù)結(jié)構(gòu)解決了此種問題:Document Values。這種結(jié)構(gòu)本質(zhì)上就是一個列式的存儲,它高度優(yōu)化了具有相同類型的數(shù)據(jù)的存儲結(jié)構(gòu)。

          為了提高效率,ElasticSearch可以將索引下某一個Document Value全部讀取到內(nèi)存中進行操作,這大大提升訪問速度,但是也同時會消耗掉大量的內(nèi)存空間。

          總之,這些數(shù)據(jù)結(jié)構(gòu)Inverted Index、Stored Fields、Document Values及其緩存,都在segment內(nèi)部。

          搜索發(fā)生時

          搜索時,Lucene會搜索所有的segment然后將每個segment的搜索結(jié)果返回,最后合并呈現(xiàn)給客戶。
          Lucene的一些特性使得這個過程非常重要:

          • Segments是不可變的(immutable)

            • Delete??當(dāng)刪除發(fā)生時,Lucene做的只是將其標(biāo)志位置為刪除,但是文件還是會在它原來的地方,不會發(fā)生改變

            • Update??所以對于更新來說,本質(zhì)上它做的工作是:先?刪除?,然后?重新索引(Re-index)

          • 隨處可見的壓縮
            Lucene非常擅長壓縮數(shù)據(jù),基本上所有教科書上的壓縮方式,都能在Lucene中找到。

          • 緩存所有的所有

          Lucene也會將所有的信息做緩存,這大大提高了它的查詢效率。

          緩存的故事

          當(dāng)ElasticSearch索引一個文件的時候,會為文件建立相應(yīng)的緩存,并且會定期(每秒)刷新這些數(shù)據(jù),然后這些文件就可以被搜索到。

          隨著時間的增加,我們會有很多segments,

          所以ElasticSearch會將這些segment合并,在這個過程中,segment會最終被刪除掉

          這就是為什么增加文件可能會使索引所占空間變小,它會引起merge,從而可能會有更多的壓縮。

          舉個栗子

          有兩個segment將會merge

          這兩個segment最終會被刪除,然后合并成一個新的segment

          這時這個新的segment在緩存中處于cold狀態(tài),但是大多數(shù)segment仍然保持不變,處于warm狀態(tài)。
          以上場景經(jīng)常在Lucene Index內(nèi)部發(fā)生的。

          在Shard中搜索

          ElasticSearch從Shard中搜索的過程與Lucene Segment中搜索的過程類似。

          與在Lucene Segment中搜索不同的是,Shard可能是分布在不同Node上的,所以在搜索與返回結(jié)果時,所有的信息都會通過網(wǎng)絡(luò)傳輸。
          需要注意的是:

          1次搜索查找2個shard = 2次分別搜索shard

          對于日志文件的處理

          當(dāng)我們想搜索特定日期產(chǎn)生的日志時,通過根據(jù)時間戳對日志文件進行分塊與索引,會極大提高搜索效率。
          當(dāng)我們想要刪除舊的數(shù)據(jù)時也非常方便,只需刪除老的索引即可。

          在上種情況下,每個index有兩個shards

          如何Scale

          shard不會進行更進一步的拆分,但是shard可能會被轉(zhuǎn)移到不同節(jié)點上

          所以,如果當(dāng)集群節(jié)點壓力增長到一定的程度,我們可能會考慮增加新的節(jié)點,這就會要求我們對所有數(shù)據(jù)進行重新索引,這是我們不太希望看到的,所以我們需要在規(guī)劃的時候就考慮清楚,如何去平衡足夠多的節(jié)點與不足節(jié)點之間的關(guān)系。

          節(jié)點分配與Shard優(yōu)化
          • 為更重要的數(shù)據(jù)索引節(jié)點,分配性能更好的機器

          • 確保每個shard都有副本信息replica

          路由Routing

          每個節(jié)點,每個都存留一份路由表,所以當(dāng)請求到任何一個節(jié)點時,ElasticSearch都有能力將請求轉(zhuǎn)發(fā)到期望節(jié)點的shard進一步處理。

          一個真實的請求

          Query

          Query有一個類型filtered,以及一個multi_match的查詢

          Aggregation

          根據(jù)作者進行聚合,得到top10的hits的top10作者的信息

          請求分發(fā)

          這個請求可能被分發(fā)到集群里的任意一個節(jié)點

          上帝節(jié)點

          這時這個節(jié)點就成為當(dāng)前請求的協(xié)調(diào)者(Coordinator),它決定:

          • 根據(jù)索引信息,判斷請求會被路由到哪個核心節(jié)點

          • 以及哪個副本是可用的

          • 等等

          路由
          在真實搜索之前

          ElasticSearch 會將Query轉(zhuǎn)換成Lucene Query

          然后在所有的segment中執(zhí)行計算

          對于Filter條件本身也會有緩存

          但queries不會被緩存,所以如果相同的Query重復(fù)執(zhí)行,應(yīng)用程序自己需要做緩存

          所以:

          • filters可以在任何時候使用

          • query只有在需要score的時候才使用

          返回

          搜索結(jié)束之后,結(jié)果會沿著下行的路徑向上逐層返回。






          源:http://dwz.date/c3fC

          版權(quán)申明:內(nèi)容來源網(wǎng)絡(luò),版權(quán)歸原創(chuàng)者所有。除非無法確認,我們都會標(biāo)明作者及出處,如有侵權(quán)煩請告知,我們會立即刪除并表示歉意。謝謝!





          感謝閱讀



          瀏覽 54
          點贊
          評論
          收藏
          分享

          手機掃一掃分享

          分享
          舉報
          評論
          圖片
          表情
          推薦
          點贊
          評論
          收藏
          分享

          手機掃一掃分享

          分享
          舉報
          <kbd id="afajh"><form id="afajh"></form></kbd>
          <strong id="afajh"><dl id="afajh"></dl></strong>
            <del id="afajh"><form id="afajh"></form></del>
                1. <th id="afajh"><progress id="afajh"></progress></th>
                  <b id="afajh"><abbr id="afajh"></abbr></b>
                  <th id="afajh"><progress id="afajh"></progress></th>
                  免费无码婬片AAAA片直播 | 欧美日韩东京热 | 欧美成人777奇米影视91色 | 成人黄色视频网 | 日本女人性高潮视频 |