带你读《Elastic Stack 实战手册》之55：——3.5.14.Watcher（3）

《Elastic Stack 实战手册》——三、产品能力——3.5 进阶篇——3.5.14.Watcher（2） https://developer.aliyun.com/article/1228142

Watcher 执行

当你添加一个 watcher 时，Watcher 会立即向 Trigger 引擎注册它的 Trigger。Trigger 引擎负责触发watch的执行，Trigger 引擎在主节点上运行，并使用与用于执行监视的线程池不同的线程池。

当 watch 被触发时，Watcher 将它排队等待执行。一个 watch_record 文档被创建并将其添加到 watch 历史索引中，并将初始状态设置为 awaits_execution。

当执行开始时，Watcher 会为 watch 创建一个 watch 执行上下文。执行上下文提供脚本和模板访问监视 metadata、payload、执行时间和 trigger 信息。

下图展示了 watch 执行过程：

应用—观察集群运行状况

你可以轻松配置一个Watch 来监控 Elasticsearch 集群的健康状况：

l 设置 watch 的触发频率并定义获取集群健康状态的输入。

l 添加评估集群运行状况以确定是否需要操作的条件。

l 如果集群为 RED，则采取措施。

设置 watch 的触发频率并添加输入

Watch schedule 控制触发 watch 的频率，watch input 获取你要评估的数据，要定期搜索日志数据并将结果加载到 watch 中。定义 schedule 的最简单方法是指定时间间隔。例如，以下计划每10秒运行一次：

curl - XPUT 'http://localhost:9200/_watcher/watch/cluster_health_watch' - d 
'{
  "trigger": {
    "schedule": {
      "interval": "10s"
    }
  }
}'

 要获取集群的状态，你可以调用 Elasticsearch 集群健康 API：

curl - XGET 'http://localhost:9200/_cluster/health?pretty'

要将健康状态加载到你的 Watch 中，你只需添加一个调用集群健康 API 的 HTTP 输入：

curl -XPUT 'http://localhost:9200/_watcher/watch/cluster_health_watch' -d 
'{
  "trigger": {
    "schedule": {
      "interval": "10s"
    }
  },
  "input": {
    "http": {
      "request": {
        "host": "localhost",
         "port": 9200,
        "path": "/_cluster/health"
      }
    }
  }
}'

《Elastic Stack 实战手册》——三、产品能力——3.5 进阶篇——3.5.14.Watcher（4） https://developer.aliyun.com/article/1228140