Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
1. elasticsearch rest client改进:使用params中的参数变量,解析配置文件中dslName对应的dsl语句,并返回解析结果 ```java ClientInterface util = (ConfigRestClientUtil) ElasticSearchHelper.getConfigRestClientUtil("demo7.xml"); Map params = new HashMap(); params.put("aaa","_&/+\"\\."); System.out.println(util.evalConfigDsl("testesencode",params)); ``` 2. 数据同步工具改进: 日志采集探针,字符串maxBytes为0或者负数时忽略长度截取 日志采集探针,增加忽略条件匹配类型:文件记录包含与排除条件匹配类型 REGEX_MATCH("REGEX_MATCH"),REGEX_CONTAIN("REGEX_CONTAIN"),STRING_CONTAIN("STRING_CONTAIN"), STRING_EQUALS("STRING_EQUALS"),STRING_PREFIX("STRING_PREFIX"),STRING_END("STRING_END"); 使用案例: ```java config.addConfig(new FileConfig(logPath,//指定目录 fileName+".log",//指定文件名称,可以是正则表达式 startLabel)//指定多行记录的开头识别标记,正则表达式 .setCloseEOF(false)//已经结束的文件内容采集完毕后关闭文件对应的采集通道,后续不再监听对应文件的内容变化 .addField("tag",fileName.toLowerCase())//添加字段tag到记录中 .setEnableInode(true) .setIncludeLines(levelArr, LineMatchType.STRING_CONTAIN) ``` 3. 数据同步工具改进:默认采用异步机制保存增量同步数据状态,提升数据同步效率,可以通过以下机制关闭异步机制: importBuilder.setAsynFlushStatus(false); 4. 客户端改进:增加dsl输出组件logDslCallback 通过组件logDslCallback,通过回调接口方法可以自定义采集dsl的执行信息:
- Loading branch information