› › ›

Watcher 链式输入

Watcher 链式输入编辑

使用 chain 输入将数据从多个来源加载到 watch 执行上下文，当 watch 被触发时。链中的输入按顺序处理，一个输入加载的数据可以被链中后续的输入访问。

chain 输入允许您根据来自多个来源的数据执行操作。您还可以使用一个输入收集的数据从另一个来源加载数据。

例如，以下链式输入使用 simple 输入设置的路径从 HTTP 服务器加载数据

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

	链中的输入被指定为一个数组，以保证输入被处理的顺序。（JSON 不保证任意对象的顺序。）
	加载 `first` 输入设置的 `path`。

访问链式输入数据编辑

要引用特定输入加载的数据，请使用输入的名称，ctx.payload.<input-name>.<value>。

转换链式输入数据编辑

在某些用例中，第一个输入的输出应该用作后续输入的输入。这需要您在将数据传递到下一个输入之前进行转换。

为了实现这一点，您可以在两个指定的输入之间使用一个转换输入，请参见以下示例。注意，第一个输入仍然以其原始形式在 ctx.payload.first 中可用。

"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}}" 
            }
          }
        }
      }
    ]
  }
}

« Watcher HTTP 输入 Watcher 触发器 »