## Accessing Data in Pipelines 在一個pipeline中定義的processors會對通過該pipeline的文檔進行讀寫操作.這些processors可以訪問源文檔的字段以及文檔的元數據字段(metadata fields.) ### [](https://www.felayman.com/articles/2017/11/24/1511515806564.html#accessing-fields-in-the-source)Accessing Fields in the Source 訪問源文檔的字段是相當簡單的,你可以直接簡單的引用他們的字段名稱。比如 ~~~ { "set": { "field": "my_field" "value": 582.1 } } ~~~ 除此之外,也可以通過_source前綴來訪問源文檔的字段,比如 ~~~ { "set": { "field": "_source.my_field" "value": 582.1 } } ~~~ ### [](https://www.felayman.com/articles/2017/11/24/1511515806564.html#accessing-metadata-fields)Accessing Metadata Fields 你可以用和訪問源文檔字段的方式一樣來訪問文檔的元數據字段。這是因為Elasticsearch不允許文檔的元數據字段和源文檔字段相同的原因. 如下的例子將會設置通過該pipeline的文檔的_id字段值為1 ~~~ { "set": { "field": "_id" "value": "1" } } ~~~ processor能夠直接訪問的文檔元數據字段有: _index, _type, _id, _routing. ### [](https://www.felayman.com/articles/2017/11/24/1511515806564.html#accessing-ingest-metadata-fields)Accessing Ingest Metadata Fields 除了元數據字段和源文檔字段,預處理節點還為通過該pipeline的文檔添加了一些ingest字段,這些字段通過_ingest變量來訪問.目前,預處理節點只添加了名稱為_ingest.timestamp的時間戳來表示Elasticsearch接收批量請求或索引請求后對文檔進行預處理的時間. 任何 processor（處理器）都可以在 document（文檔）處理期間添加與 ingest 相關的 metadata（元數據）。Ingest metadata 是 transient（瞬時的），并且在 pipeline（管道）處理 document（文檔）后丟失。因此，ingest metadata 將不會被索引。 以下示例添加了一個名為 received 的 field（字段），它的值是 ingest 的 timestamp : ~~~ { "set": { "field": "received" "value": "{{_ingest.timestamp}}" } } ~~~ 與 Elasticsearch metadata fields 不一樣的是，這個名為 _ingest 的 metadata fields 可以作為 source of document（源文檔）中的有效名稱。使用 _source._ingest 來引用 source document（源文檔）中的 field（字段）。否則，_ingest 將會被作為一個 ingest metadata field 來解釋。 ### [](https://www.felayman.com/articles/2017/11/24/1511515806564.html#accessing-fields-and-metafields-in-templates)Accessing Fields and Metafields in Templates 一些 processor（處理器）的設置也支持模板化。所支持模版的設置可以有零到多個 template snippets（模版片段）。一個 template snippets（模版片段）以 {{ 開始并以 }} 結束。在模板中訪問 field（字段）和 metadata（元數據）與通過普通的 processor（處理器）field（字段）設置完全相同。 以下示例添加了一個名為 field_c 的 field（字段）。它的值為 field_a 和 field_b 的值的 concatenation（串聯）。 ~~~ { "set": { "field": "field_c" "value": "{{field_a}} {{field_b}}" } } ~~~ 以下示例使用 source（源文檔）中 geoip.country_iso_code 字段的值來設置 document 將要被索引到的 index（索引）。 ~~~ { "set": { "field": "_index" "value": "{{geoip.country_iso_code}}" } } ~~~ 還支持動態字段名。此示例設置以服務值命名的字段，以字段代碼的值 ~~~ { "set": { "field": "{{service}}" "value": "{{code}}" } } ~~~