身安不如心安,屋宽不如心宽 。
Filter

Filter

如何处理文本中带有数字连号的范围段搜索?

默认分类God_lockin 回复了问题 • 2 人关注 • 1 个回复 • 2314 次浏览 • 2022-12-19 11:49 • 来自相关话题

Filter过滤上下文的性能疑问

Elasticsearchpony_maggie 回复了问题 • 3 人关注 • 2 个回复 • 1815 次浏览 • 2020-08-09 18:24 • 来自相关话题

logstash如何实现多对多匹配filter?

Logstashtacsklet 回复了问题 • 2 人关注 • 1 个回复 • 3869 次浏览 • 2020-01-07 15:39 • 来自相关话题

logstash 可以同时应用多个filter,filter的顺序如何控制?

Logstashsilver9527 回复了问题 • 2 人关注 • 3 个回复 • 6358 次浏览 • 2020-01-06 16:00 • 来自相关话题

range keyword 与日期 查询顺序性能

ElasticsearchOmbres 回复了问题 • 2 人关注 • 1 个回复 • 2483 次浏览 • 2019-12-09 15:19 • 来自相关话题

使用filter + composite aggregation的问题

Elasticsearchsailershen 回复了问题 • 3 人关注 • 2 个回复 • 4386 次浏览 • 2019-07-23 19:43 • 来自相关话题

filter查询不到数据,字段值一样,mapping也没有发现什么不一样。

Elasticsearchrochy 回复了问题 • 3 人关注 • 2 个回复 • 3310 次浏览 • 2019-02-13 15:57 • 来自相关话题

关于elasticsearch中filter的粒度的疑问

Elasticsearchkennywu76 回复了问题 • 4 人关注 • 1 个回复 • 3506 次浏览 • 2019-01-07 14:37 • 来自相关话题

logstash日志grok然后output问题

Logstashrochy 回复了问题 • 2 人关注 • 1 个回复 • 3377 次浏览 • 2018-12-11 11:16 • 来自相关话题

ElasticSearch2.4.6 + Spring-data filter功能不正常

回复

Elasticsearchlinfujian 回复了问题 • 2 人关注 • 3 个回复 • 3451 次浏览 • 2018-09-07 10:55 • 来自相关话题

Logstash tcp syslog日志分字段

LogstashUnigroupAi 回复了问题 • 2 人关注 • 1 个回复 • 3175 次浏览 • 2018-06-28 12:54 • 来自相关话题

elasticsearch6.0 buckets key 再过滤

Elasticsearchxiaofancn 回复了问题 • 4 人关注 • 2 个回复 • 3726 次浏览 • 2018-06-04 14:29 • 来自相关话题

logstash-filter-elasticsearch的简易安装

Logstashziyou 发表了文章 • 0 个评论 • 3639 次浏览 • 2018-05-29 09:38 • 来自相关话题

不同版本的logstash集成的插件不一样,在5.6版本就未集成logstash-filter-elasticsearch插件,所以需要自己安装。 官方提供的方法因为需要联网,并且需要调整插件管理源,比较麻烦,针对logstash-filter-elasticsearch插件,使用下面这种方式安装。 logstash-filter-elasticsearch插件安装 1、在git上下载logstash-filter-elasticsearch压缩包,logstash-filter-elasticsearch.zip, 2、在logstash的目录下新建plugins目录,解压logstash-filter-elasticsearch.zip到此目录下。 3、在logstash目录下的Gemfile中添加一行:
gem "logstash-filter-elasticsearch", :path => "./plugins/logstash-filter-elasticsearch"
4、重启logstash即可。   此方法适用logstash-filter-elasticsearch,但不适用全部logstash插件。

logstash中的filter中适合写入复杂的处理逻辑吗?

Logstashvenyowang 回复了问题 • 2 人关注 • 1 个回复 • 3026 次浏览 • 2018-01-19 09:25 • 来自相关话题

有一组没有key的list集合的数据,自己怎么写过滤器,在值前面加自己想要的key

回复

LogstashK_ID 发起了问题 • 1 人关注 • 0 个回复 • 2300 次浏览 • 2017-12-08 14:51 • 来自相关话题

如何处理文本中带有数字连号的范围段搜索?

回复

默认分类God_lockin 回复了问题 • 2 人关注 • 1 个回复 • 2314 次浏览 • 2022-12-19 11:49 • 来自相关话题

Filter过滤上下文的性能疑问

回复

Elasticsearchpony_maggie 回复了问题 • 3 人关注 • 2 个回复 • 1815 次浏览 • 2020-08-09 18:24 • 来自相关话题

logstash如何实现多对多匹配filter?

回复

Logstashtacsklet 回复了问题 • 2 人关注 • 1 个回复 • 3869 次浏览 • 2020-01-07 15:39 • 来自相关话题

logstash 可以同时应用多个filter,filter的顺序如何控制?

回复

Logstashsilver9527 回复了问题 • 2 人关注 • 3 个回复 • 6358 次浏览 • 2020-01-06 16:00 • 来自相关话题

range keyword 与日期 查询顺序性能

回复

ElasticsearchOmbres 回复了问题 • 2 人关注 • 1 个回复 • 2483 次浏览 • 2019-12-09 15:19 • 来自相关话题

使用filter + composite aggregation的问题

回复

Elasticsearchsailershen 回复了问题 • 3 人关注 • 2 个回复 • 4386 次浏览 • 2019-07-23 19:43 • 来自相关话题

filter查询不到数据,字段值一样,mapping也没有发现什么不一样。

回复

Elasticsearchrochy 回复了问题 • 3 人关注 • 2 个回复 • 3310 次浏览 • 2019-02-13 15:57 • 来自相关话题

关于elasticsearch中filter的粒度的疑问

回复

Elasticsearchkennywu76 回复了问题 • 4 人关注 • 1 个回复 • 3506 次浏览 • 2019-01-07 14:37 • 来自相关话题

logstash日志grok然后output问题

回复

Logstashrochy 回复了问题 • 2 人关注 • 1 个回复 • 3377 次浏览 • 2018-12-11 11:16 • 来自相关话题

ElasticSearch2.4.6 + Spring-data filter功能不正常

回复

Elasticsearchlinfujian 回复了问题 • 2 人关注 • 3 个回复 • 3451 次浏览 • 2018-09-07 10:55 • 来自相关话题

Logstash tcp syslog日志分字段

回复

LogstashUnigroupAi 回复了问题 • 2 人关注 • 1 个回复 • 3175 次浏览 • 2018-06-28 12:54 • 来自相关话题

elasticsearch6.0 buckets key 再过滤

回复

Elasticsearchxiaofancn 回复了问题 • 4 人关注 • 2 个回复 • 3726 次浏览 • 2018-06-04 14:29 • 来自相关话题

logstash中的filter中适合写入复杂的处理逻辑吗?

回复

Logstashvenyowang 回复了问题 • 2 人关注 • 1 个回复 • 3026 次浏览 • 2018-01-19 09:25 • 来自相关话题

有一组没有key的list集合的数据,自己怎么写过滤器,在值前面加自己想要的key

回复

LogstashK_ID 发起了问题 • 1 人关注 • 0 个回复 • 2300 次浏览 • 2017-12-08 14:51 • 来自相关话题

能否只比较小时不比较天?

回复

Kibanakennywu76 回复了问题 • 4 人关注 • 2 个回复 • 3001 次浏览 • 2017-11-13 16:12 • 来自相关话题

logstash-filter-elasticsearch的简易安装

Logstashziyou 发表了文章 • 0 个评论 • 3639 次浏览 • 2018-05-29 09:38 • 来自相关话题

不同版本的logstash集成的插件不一样,在5.6版本就未集成logstash-filter-elasticsearch插件,所以需要自己安装。 官方提供的方法因为需要联网,并且需要调整插件管理源,比较麻烦,针对logstash-filter-elasticsearch插件,使用下面这种方式安装。 logstash-filter-elasticsearch插件安装 1、在git上下载logstash-filter-elasticsearch压缩包,logstash-filter-elasticsearch.zip, 2、在logstash的目录下新建plugins目录,解压logstash-filter-elasticsearch.zip到此目录下。 3、在logstash目录下的Gemfile中添加一行:
gem "logstash-filter-elasticsearch", :path => "./plugins/logstash-filter-elasticsearch"
4、重启logstash即可。   此方法适用logstash-filter-elasticsearch,但不适用全部logstash插件。

你应该了解的5个 Logstash Filter 插件

Logstashdongne 发表了文章 • 1 个评论 • 3022 次浏览 • 2017-10-25 21:46 • 来自相关话题

Day6:《记一次es性能调优》

Elasticsearchxiaorui 发表了文章 • 5 个评论 • 13159 次浏览 • 2016-12-13 11:49 • 来自相关话题

一.前言 应medcl写es文章的时候,其实这段时间es研究的不多,感觉没什么新东西可写。 考虑只有这次调优心得可与大家分享,文笔有限,见谅! 二.背景 先交代一下背景,调优的项目是某电商类搜索项目,流量来自于前端的app和h5。 搜索主要是根据用户的地理位置和关键字等条件搜索附近的商家和商品。 商品数据大概在5000w左右,商品更新很频繁,更新量大概是每天2000w条左右,(因商家经常会促销、或者调上下架状态、改价格等)查询也相当频繁。 集群有2个集群,一个主一个备,用于有问题的时候随时切换。主集群有8个节点,配置是32核, 32g内存的docker的机器。给es jvm分配20g内存,jdk 版本是1.7,gc 是使用parnew/cms gc。 这个项目我是后期加入的,来的时候项目已上线。由于参与进来的时候es跑的也还是比较稳定,所以也一直 没调过es的参数。程序,参数基本上也就保持上线的时候那个样子。 es上线的时候是用的1.5版本,后期没升过级。 三.问题 项目大概跑了一年多,时间来到大概16年的9月份。搜索请求响应时间开始出现几秒才完成的情况, 我就被拉过来调优了。通过我们自己内部的调用方法监控,tp99和avg这些值还好,维持在200ms以下。max 最大有5,6s的情况,而且次数有点多。 这里没怎么折腾,很快定位就是es gc导致的。翻了一下es gc日志,就是cms remark这个阶段时间特别长, 而且 这个阶段是stop the world的。 四.解决 为什么remark阶段这么长时间? 直接上结论,就是一次cms 周期内,并发标记后到remark这个期间jvm 堆内存对象 变化很大。说白了对应我们的场景就是一大波 es bulk操作。对应Bigdesk观察,几秒的卡顿基本都出现在一大波 es bulk操作之后。 这里解释一下,引用网上文章的说法: remark如果耗时较长,通常原因是在cms gc已经结束了concurrent-mark步骤后,旧生代的引用关系仍然发生了很多的变化,旧生代的引用关系发生变化的原因主要是: * 在这个间隔时间段内,新生代晋升到旧生代的对象比较多; * 在这个间隔时间段内,新生代没怎么发生ygc,但创建出来的对象又比较多,这种通常就只能是新生代比较大的原因; 原文地址: http://hellojava.info/?tag=cms-gc-remark 调整一: 加cms gc 的 线程 直接从根源入手,你remark 慢,我就让你跑快点。 因为我们是32 核的cpu ,cpu 利用率用bigdesk观察还是很低的,5%左右。这么低,那就加点线程呗。 -XX:ParallelGCThreads= N -XX:ParallelCMSThreads= M 调整这2个参数都可以,它们的关系:ParallelCMSThreads = (ParallelGCThreads + 3)/4) 调整后情况缓解了一些,remark还是有3,4秒的情况。 调整二: 关于这点是我们自己的问题。一次bulk 操作就写1条数据。 是的,你没有看错,我们这边的工程师就是这么干的。 一年以前提过这里最好是能合并写,但现在还是这个样子。 这里有一些业务上的原因,合并写会导致一些字段值不准确。 合并写暂时没办法,只能调整es 了。(这里说明一下,其实合并写应该是本次优化比较有效果的办法,可惜这招不让我用。) 通过bigdesk观察,bulk线程池有reject的情况。 但就增加bulk线程池的消费线程,加快数据的消费速度,减少对象驻留在jvm 的时间。 调整后情况没有明显的好转, 但肯定有用,能优化一点是一点嘛。 调整三: 再次从gc入手, -XX:+CMSParallelRemarkEnabled -XX:+CMSScavengeBeforeRemark 这个是网上找的办法: 为了减少第二次暂停的时间,开启并行remark: -XX:+CMSParallelRemarkEnabled。 如果remark还是过长的话,可以开启-XX:+CMSScavengeBeforeRemark选项,强制 remark之前开始一次minor gc,减少remark的暂停时间,但是在remark之后也将立即开始又一次minor gc。调整后情况也没有特别的好转。 以上都是从减小单次cms gc的开销的方向去解决问题,然后我就换了个方向,降低cms gc发生的次数,让它少发生或者不发生。 调整四: 这里调整了一共5个参数, Xmn10g ==> 8g CMSInitiatingOccupancyFraction=70 ==>80 index.cache.filter.max_size 2g==>1g index.cache.filter.expire 2m==>40s index.refresh_interval 20s==>30s 前2个参数没什么好说的,提高cms gc 被触发的条件,降低cms gc 触发几率。 后3个参数是本文的重点,这里大概讲下es 对于filter cache的管理。 这部分是通过阅读源码分析出来的,涉及代码还挺多,有点复杂,还有很大一部分还是lucene的代码。 这里就不贴大段代码了。 es 对于 filter cache管理是内部维护了一个map的结构(实际是利用com.google.common.cache实现的),关键是这个map 的key 是个它自己定义的类 叫 FilterCacheKey,它override了equals方法 public FilterCacheKey(Object readerKey, Object filterKey) {     this.readerKey = readerKey;     this.filterKey = filterKey; } ... @Override public boolean equals(Object o) {     if (this == o) return true; //            if (o == null || getClass() != o.getClass()) return false;     FilterCacheKey that = (FilterCacheKey) o;     return (readerKey().equals(that.readerKey()) && filterKey.equals(that.filterKey)); } 从这里可以看出,filter cache 能否被再次利用到就跟readerKey和filterKey 有关。 filterkey如果你build 查询语句的时候什么都没设置的话,就是filter对象本身。 举个例子,TermFilter,如果term一样,那前后2次查询filterKey是一致的。 关键是这个readerKey是否一致呢?这个readerKey其实就是lucene 的 indexReader,如果前后2次查询有数据更新并且 index.refresh_interval 这个参数设置的比较小,es 会去刷新indexReader,那么很有可能readerKey不一致。 对应我们的场景,数据更新频繁,而且index.refresh_interval 比较小,那么缓存利用率就不太高。 后一次查询的filter cache 会重新put 到上面提到的map里,然后这个index.cache.filter.max_size 2g  就迅速占满(我们程序代码里很多地方使用到了filter),配多大都有可能占满。那这个filter cache什么时候被移除呢,index.cache.filter.expire 2m管移除这个事,当然应该还有size满了移除的策略。 这就造成了缓存没什么用,还占这么大地方,还占那么久。 然后这个filter cache就很可能跑到 old gen去了。 那么就让它占少点,不干活就快点走: index.cache.filter.max_size 2g==>1g index.cache.filter.expire 2m==>40s index.refresh_interval 20s==>30s 这些调整完毕,重启es ,通过bigdesk ,gc a线图好看多了,cms gc 基本没了,monitor gc 也顺畅多了。 五.总结和备注 总结: 1.优化这个事,我认为是业务上的优化要比技术上优化有效的多 2.日志和监控是你最好的朋友,仔细的看,你总会看出什么 3.es 缓存要利用好,还是需要好好去设计,回头考虑单独写一篇。 备注: 因为这次优化后,我就离开了原来的公司,没有了原来的环境。所以本文 部分参数和数字可能不准确,我仅凭记忆完成。