本文将介绍如何安装Watcher服务,并介绍相关的功能特征。
1.Watcher服务的安装
目前Watcher服务处于Beta阶段,使用者可以申请最新的beta-key,然后通过插件的方式进行安装
bin/plugin -i elasticsearch/watcher/<watcher-beta-key>
2.验证服务
curl -XGET 'http://192.168.100.72:9200/_watcher/stats?pretty' 或者直接通过浏览器访问也是可以的
3.版本要求
Watcher需要ElasticSearchV1.5.0+版本
案例介绍一:
监控错误数据案例,每10秒搜索一次数据,发现错误后,记录一条错误记录。
配置流程:
1.设置定时器和输入源(错误数据的查询条件)
2.设置触发条件(是否查询到了错误数据)
3.设置触发动作(发现错误后执行Action)
设置详情:
1.每10秒搜索一次日志数据
curl -XPUT 'http://192.168.100.72:9200/_watcher/watch/log_error_watch' -d '{ "trigger" : { "schedule" : { "interval" : "10s" } }, "input" : { "search" : { "request" : { "indices" : [ "logs" ], "body" : { "match" : { "message": "error" } } } } } }'
2.数据加载情况历史记录
curl -XGET 'http://192.168.100.72:9200/.watch_history*/_search?pretty' -d '{ "sort" : [ { "execution_result.execution_time" : "desc" } ] }'
从返回结果中可以看到每10秒触发一次查询操作,如果历史记录中无数据,表示没有搜索到数据。
3.如何设置条件
curl -XPUT 'http://192.168.100.72:9200/_watcher/watch/log_error_watch' -d '{ "trigger" : { "schedule" : { "interval" : "10s" } }, "input" : { "search" : { "request" : { "indices" : [ "logs" ], "body" : { "query" : { "match" : { "message": "error" } } } } } }, "condition" : { #设置条件,结果数据是否大于0!即是否查询到了数据 "compare" : { "ctx.payload.hits.total" : { "gt" : 0 }} } }'
3.查询触发条件执行状态
#查询Watcher的历史记录,验证触发条件是否被触发了 curl -XGET 'http://192.168.100.72:9200/.watch_history*/_search?pretty' -d '{ "query" : { "bool" : { "must" : [ { "match" : { "execution_result.condition.met" : true }}, { "range" : { "execution_result.execution_time" : { "from" : "now-10s"}}} ] } } }'
4.设置动作
curl -XPUT 'http://192.168.100.72:9200/_watcher/watch/log_error_watch' -d '{ "trigger" : { "schedule" : { "interval" : "10s" } }, "input" : { "search" : { "request" : { "indices" : [ "logs" ], "body" : { "query" : { "match" : { "message": "error" } } } } } }, "condition" : { "compare" : { "ctx.payload.hits.total" : { "gt" : 0 }} }, "actions" : { #触发动作,这里可以使 记录日志,发送邮件,发送到第三方的WebHook等等。 "log_error" : { "logging" : { "text" : "Found {{ctx.payload.hits.total}} errors in the logs" } } } }'
案例介绍二:
监控ElasticSearch集群状态:每10秒检测一次集群状态,如果集群状态错误,则发送邮件给运维
配置流程就不过多介绍了,直接来结果。
curl -XPUT 'http://192.168.100.72:9200/_watcher/watch/cluster_health_watch' -d '{ "trigger" : { "schedule" : { "interval" : "10s" } }, "input" : { "http" : { "request" : { "host" : "192.168.100.72", "port" : 9200, "path" : "_cluster/health" } } }, "condition" : { "compare" : { "ctx.payload.status" : { "eq" : "red" } } }, "actions" : { "send_email" : { "email" : { "to" : "corejava2008@163.com", "subject" : "ES Cluster Status Warning", "body" : "ES Cluster status is RED" } } } }' 请注意,如果配置邮件发送,需要在ElasticSearch配置文件中配置以下信息 watcher.actions.email.service.account: work: profile: gmail email_defaults: from: <email> smtp: auth: true starttls.enable: true host: smtp.gmail.com port: 587 user: <username> password: <password>
相关推荐
适用于7.17.1系列,例如Elasticsearch的7.17.12版本。 elasticsearch-analysis-ik 是一个常用的中文分词器,在 Elasticsearch 中广泛应用于中文文本的分析和搜索。下面是 elasticsearch-analysis-ik 分词器的几个...
`elasticsearch-jieba-plugin`正是将jieba分词库与Elasticsearch进行了深度融合,使得ES在处理中文文本时能展现出卓越的性能。 安装此插件的过程简单明了。首先,下载`elasticsearch-jieba-plugin 8.8.2.zip`压缩包...
以下是对"elasticsearch-head-master安装及下载"的详细步骤和相关知识点的说明。 **1. 下载Elasticsearch Head** 首先,你需要从GitHub等开源平台下载Elasticsearch Head的最新源码包,通常是ZIP或TGZ格式。确保...
4. 启动Elasticsearch:安装完成后,重启Elasticsearch服务,让插件生效。 五、配置与使用 1. 配置分词器:在Elasticsearch的索引模板或映射设置中,添加IK分词器配置,例如: ```json { "settings": { ...
最新版 elasticsearch-analysis-ik-8.7.0.zip最新版 elasticsearch-analysis-ik-8.7.0.zip最新版 elasticsearch-analysis-ik-8.7.0.zip最新版 elasticsearch-analysis-ik-8.7.0.zip
安装IK分词器通常需要将jar文件复制到Elasticsearch的plugins目录,然后重启Elasticsearch服务。在使用过程中,可以通过Elasticsearch的配置文件(如elasticsearch.yml)设置分词器参数,或者在创建索引时指定分词器...
Elasticsearch(ES)是一款功能强大的全文搜索引擎,广泛应用于数据检索、数据分析等领域。为了提高搜索的准确性和便利性,Elasticsearch提供了丰富的分析插件,其中"elasticsearch-analysis-dynamic-synonym-7.2.0...
Elasticsearch(简称ES)是一款强大的开源搜索引擎,广泛应用于大数据领域的全文检索。它以其高可扩展性、实时性能以及丰富的分析能力著称。在中文环境下,由于汉字的复杂性,分词是实现有效搜索的关键步骤。为此,...
最新版elasticsearch-analysis-ik-8.8.2.zip最新版elasticsearch-analysis-ik-8.8.2.zip最新版elasticsearch-analysis-ik-8.8.2.zip最新版elasticsearch-analysis-ik-8.8.2.zip
1. **下载与安装**:将`elasticsearch-analysis-dynamic-synonym-7.6.2.jar`文件复制到ES的`plugins`目录下,然后重启ES服务,系统会自动识别并加载插件。 2. **配置文件**:创建`synonyms.txt`文件,包含同义词...
本文将详细介绍elasticsearch-analysis-ik-7.10.2,一个专为Elasticsearch设计的高效中文分词插件。 1. **Elasticsearch简介** Elasticsearch是一种基于Lucene的分布式、实时的搜索和分析引擎。它提供了 RESTful ...
安装IK分词器通常涉及下载jar包,将其放入Elasticsearch的plugins目录下,并重启Elasticsearch服务。配置方面,用户可以在Elasticsearch的配置文件中指定分词器参数,如自定义词典路径,或者通过API动态调整设置。 ...
安装 Elasticsearch-analysis-ik 插件非常简单,只需在 Elasticsearch 根目录下执行命令 `bin/elasticsearch-plugin install analysis-ik`,然后重启 Elasticsearch 服务。在配置文件 `elasticsearch.yml` 中可以...
安装完成后,重启Elasticsearch服务,插件即可生效。 在配置Elasticsearch索引时,我们需要指定使用IK分词器。这通常在创建索引的mapping中完成,通过设置`analyzer`字段为`ik_max_word`或`ik_smart`来选择不同的...
《Elasticsearch 8.2.0 中文分词器详解及应用》 Elasticsearch(ES)作为一款强大的开源搜索引擎,广泛应用于大数据处理和信息检索领域。在处理中文文本时,选择合适的分词器至关重要,elasticsearch-analysis-ik-...
安装`elasticsearch-analysis-ik-7.9.3`插件时,通常需要将整个压缩包解压后,将`elasticsearch-analysis-ik-7.9.3.jar`及其依赖文件放入Elasticsearch的`plugins`目录下,然后重启Elasticsearch服务,插件就会自动...
1. **安装**:将压缩包解压后,将jar文件复制到Elasticsearch的plugins目录下,重启Elasticsearch服务即可。 2. **配置**:根据需求修改config目录下的配置文件,例如设置分词模式、添加自定义词典等。 3. **测试**...
一旦你下载并解压缩了"elasticsearch-analysis-dynamic-synonym-7.0.0.zip",你需要将解压后的目录移动到你的Elasticsearch安装目录下的"plugins"文件夹。这样就完成了插件的基本安装。在执行此操作后,记得删除原始...
安装IK分词器时,通常需要将jar文件放入ES的lib目录下,并在ES配置文件elasticsearch.yml中添加插件的配置。使用时,可以通过设置索引的分析器为"ik_max_word"或"ik_smart",来启用IK分词器。 总的来说,"elastic...
Elasticsearch-HQ是一款强大的Elasticsearch管理工具,尤其对于那些需要通过图形用户界面来监控、管理和查询Elasticsearch集群的用户来说,它是一个不可或缺的辅助插件。这个"elasticsearch-HQ-master.zip"文件包含...