## Handling Failures in Pipelines 在最簡單的 use case（使用案例）中，一個 pipeline（管道）定義了一個順序指定的 processor（處理器）的列表，并且會在第一個 exception（異常）發生時終止處理。當預期出現故障時，這種行為可能不是令人滿意的。例如，您可能有與指定的 grok expression 不匹配的 log（日志）。您可能希望將這些 （文檔）編入一個單獨的 index（索引），而不是停止執行。 為了啟用這種行為，您可以使用 on_failure 參數。該 on_failture 參數定義了要在故障的 processor（處理器）之后立即執行的 processor （處理器）列表。你可以在 pipeline（管道）級別，以及 processor（處理器）級別指定該參數。如果 processor（處理器）指定了 on_failure 配置，無論它是否為空，任何 processor（處理器）拋出的 exception（異常）都會被 catch（捕獲）。并且 pipeline（管道）繼續執行剩余的 processors（處理器）。因為您可以在 on_failure 語句范圍內定義進一步的 processor（處理器），您還可以 nest（嵌套）故障處理。 以下示例定義了一個在文檔處理時重命名 foo 為 bar 字段的 pipeline（管道）。如果 document（文檔）不包含 foo 字段，該 processor 將會附帶一個 error（錯誤）信息到文檔，以便以后在 Elasticsearch 中進行分析。 ~~~ { "description" : "my first pipeline with handled exceptions", "processors" : [ { "rename" : { "field" : "foo", "target_field" : "bar", "on_failure" : [ { "set" : { "field" : "error", "value" : "field \"foo\" does not exist, cannot rename to \"bar\"" } } ] } } ] } ~~~ 以下示例在整個 pipeline（管道）級別上定義了一個 on_failure 塊，它用于更改發送失敗的 document（文檔）的 index（索引）。 ~~~ { "description" : "my first pipeline with handled exceptions", "processors" : [ ... ], "on_failure" : [ { "set" : { "field" : "_index", "value" : "failed-{{ _index }}" } } ] } ~~~ 或者，在處理器故障的情況下，不是定義行為，還可以通過指定 ignore_failure 設置來忽略故障并繼續下一個 processor（處理器）。 在下面的例子中，如果字段 foo 不存在，故障將被捕獲并且 pipeline（管道）繼續執行，在這種情況下意味著 pipeline（管道）什么都不做。 ~~~ { "description" : "my first pipeline with handled exceptions", "processors" : [ { "rename" : { "field" : "foo", "target_field" : "bar", "ignore_failure" : true } } ] } ~~~ 該 ignore_failure 可以設置在任何 processor（處理器）上且默認值為 false。 Accessing Error Metadata From Processors Handling Exceptions（從處理器處理的異常中訪問錯誤的元數據） 您也許想要獲取 processor（處理器）所拋出的真實的 error message（錯誤信息）。要做到這一點，您可以訪問名為 on_failure_message，on_failure_processor_type 和 on_failure_processor_tag 的 metadata fields（元數據字段）。這些 fileds（字段）只能從 on_failure 塊的上下文中訪問。 這是您之前看到的示例的一個更新版本。但是，該示例不是手動設置 error message（錯誤信息），而是使用 on_failure_message 元數據字段來提供 error message（錯誤信息）。 ~~~ { "description" : "my first pipeline with handled exceptions", "processors" : [ { "rename" : { "field" : "foo", "to" : "bar", "on_failure" : [ { "set" : { "field" : "error", "value" : "{{ _ingest.on_failure_message }}" } } ] } } ] } ~~~