Входная цепочка Watcher

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

Вход chain позволяет выполнять действия на основе данных из нескольких источников. Вы также можете использовать данные, собранные одним входом, для загрузки данных из другого источника.

Например, следующий входной цепочкой загружает данные с HTTP-сервера, используя путь, заданный входом simple:

"input" : {
  "chain" : {
    "inputs" : [ 
      {
        "first" : {
          "simple" : { "path" : "/_search" }
        }
      },
      {
        "second" : {
          "http" : {
            "request" : {
              "host" : "localhost",
              "port" : 9200,
              "path" : "{{ctx.payload.first.path}}" 
            }
          }
        }
      }
    ]
  }
}

"input" : {
  "chain" : {
    "inputs" : [ 
      {
        "first" : {
          "simple" : { "path" : "/_search" }
        }
      },
      {
        "second" : {
          "transform" : {
            "script" : "return [ 'path' : ctx.payload.first.path + '/' ]"
          }
        }
      },
      {
        "third" : {
          "http" : {
            "request" : {
              "host" : "localhost",
              "port" : 9200,
              "path" : "{{ctx.payload.second.path}}" 
            }
          }
        }
      }
    ]
  }
}