日志数据冗余且庞大,使用es的rollup功能可以预先对数据做处理,节省数据存储空间。
基本功能初识
rollup位于es x-pack包,本文使用的es版本是7.2.0。这里主要讨论rollup api对应的start和search功能,同时对于rollup的搜索和普通的搜索有什么区别。
rollup 基本使用
具体如何创建、删除、查看、启停rollup服务参看elasticsearch的官方文档。
rollup start
rollup创建完成后需要调用start才能开始执行,默认是stop状态
POST /_rollup/job/{id}/_start |
这个请求会落到TransportStartRollupAction
的taskOperation,接着调用RollupJobTask
的start,然后调用RollupIndexer
类的实现ClientRollupPageManager
执行搜索和bulk操作,