Преобразование данных payloads цепочки Watcher

Преобразование данных payloads, которое выполняет упорядоченный список настроенных преобразований данных payloads в цепочке, где выход одного преобразования служит входом следующего преобразования в цепочке. Payload, принимаемый этим преобразованием, используется в качестве входных данных для первого преобразования в цепочке, а выход последнего преобразования в цепочке является результатом всего преобразования chain.

Вы можете использовать цепочки преобразований данных payloads для создания более сложных преобразований из других доступных преобразований. Например, вы можете объединить преобразование данных payloads search и преобразование данных payloads script, как показано в следующем фрагменте:

"transform" : {
  "chain" : [ 
    {
      "search" : {  
        "indices" : [ "logstash-*" ],
        "body" : {
          "size" : 0,
          "query" : {
            "match" : { "priority" : "error" }
          }
        }
      }
    },
    {
      "script" : "return [ error_count : ctx.payload.hits.total ]"  
    }
  ]
}

Этот пример выполняет поиск count в кластере для поиска событий error. Результаты поиска передаются во второе преобразование данных payloads script. Преобразование данных payloads script извлекает общее количество совпадений и присваивает его полю error_count в вновь сгенерированном payload. Этот новый payload является результатом преобразования данных payloads chain и заменяет payload в контексте выполнения watch.