Преобразование полезной нагрузки цепочки Watcher

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

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

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

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