elasticsearch - 使用 Watcher 和 Kibana 监控电子邮件日志,在最后一分钟内每分钟触发一次

标签 elasticsearch logging logstash kibana elastic-stack

需要在 Kibana 中创建观察者,每分钟触发一次并在最后一分钟内搜索特定日志并相应地拍摄和发送电子邮件

最佳答案

能够在高级 watch 中创建以下内容

{   "trigger": {
    "schedule": {
      "interval": "1m"
    }   },   "input": {
    "search": {
      "request": {
        "search_type": "query_then_fetch",
        "indices": [
          "*"
        ],
        "rest_total_hits_as_int": true,
        "body": {
          "size": 0,
          "query": {
            "bool": {
              "filter": {
                "range": {
                  "@timestamp": {
                    "gte": "{{ctx.trigger.scheduled_time}}||-1m",
                    "lte": "{{ctx.trigger.scheduled_time}}",
                    "format": "strict_date_optional_time||epoch_millis"
                  }
                }
              }
            }
          }
        }
      }
    }   },   "condition": {
    "script": {
      "source": "if (ctx.payload.hits.total > params.threshold) { return true; } return false;",
      "lang": "painless",
      "params": {
        "threshold": 0
      }
    }   },   "actions": {
    "email_action": {
      "email": {
        "profile": "standard",
        "attachments": {
          "attached_data": {
            "data": {
              "format": "json"
            }
          }
        },
        "to": [
          "myemail@gmail.com"
        ],
        "subject": "Winlog Errors Encountered {{ctx.payload.hits.total}} logs",
        "body": {
          "text": "Too many logs in the system, see attached data"
        }
      }
    }   } }

关于elasticsearch - 使用 Watcher 和 Kibana 监控电子邮件日志,在最后一分钟内每分钟触发一次,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58819662/

相关文章:

mysql - 使用哪种策略来设计日志数据存储?

python - 如何检查Python日志的最大错误级别?

elasticsearch - Elasticsearch所有节点的一个存储

elasticsearch - 在 Elasticsearch 中检索热门术语查询

python - 如何使用 REST 请求通过 python 脚本加载 Kibana 可视化

elasticsearch - Elasticsearch时间字段和范围查询

elasticsearch - SQL 子查询的 ElasticSearch 等价物是什么?

AWS Beanstalk 上的 Python。如何快照自定义日志?

mysql - 使用logstash Elasticsearch输出插件报错: NameError: SSLConnectionSocketFactory not found

logstash - GROK 中的日志级别模式