分享

flume 的 agents.sinke.s1.serializer.regex 的正则表达式属性怎么设置

小新嘟嘟 发表于 2017-8-4 19:57:34 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 6 6507
数据格式   
2017-08-02 13:10:19.094|HSFBizProcessor-5-thread-155|DEBUG|setMember begin typeId=[qps_push_waybill], key=[9891003749887], expireTime=[15552000]
2017-08-02 13:10:19.097|HSFBizProcessor-5-thread-155|DEBUG|CoralCacheJedisImpl(351).setMember()|pipeline started
2017-08-02 13:10:19.097|HSFBizProcessor-5-thread-155|DEBUG|realkey=[qps_push_waybill:9891003749887]

根据 | 分割数据 保存到 一个列镞  4个列中  c1 c2 c3 c4  
flume 的  agents.sinke.s1.serializer.regex 这个属性怎么配置

agents.sinke.s1.serializer.regex =^([^|]+),([^|]+),([^|]+),([^|]+)$  这么写不起作用

已有(6)人评论

跳转到指定楼层
w123aw 发表于 2017-8-4 20:26:00
试试这个[^|]*?[|]?
回复

使用道具 举报

小新嘟嘟 发表于 2017-8-4 20:28:48
w123aw 发表于 2017-8-4 20:26
试试这个[^|]*?[|]?

agents.sinke.s1.serializer.regex =[^|]*?[|]?,[^|]*?[|]?,[^|]*?[|]?,[^|]*?[|]?  x写四遍吗?
回复

使用道具 举报

w123aw 发表于 2017-8-4 20:31:11
小新嘟嘟 发表于 2017-8-4 20:28
agents.sinke.s1.serializer.regex =[^|]*?[|]?,[^|]*?[|]?,[^|]*?[|]?,[^|]*?[|]?  x写四遍吗?

一遍即可
回复

使用道具 举报

小新嘟嘟 发表于 2017-8-4 20:32:47
我试试去 谢谢了 不会在请教
回复

使用道具 举报

小新嘟嘟 发表于 2017-8-4 22:15:14

不好使 我试了下
回复

使用道具 举报

J20_果农 发表于 2017-8-5 13:52:36
试试这个正则分组, 格式必须是固定的

([\\S\\s]*)\\|(\\S+)\\|([\\S\\s]*)\\|([\\S\\s]*)

下面是java版本带分组名的
(?<g1>[\\S\\s]*)\\|(?<g2>\\S+)\\|(?<g3>[\\S\\s]*)\\|(?<g4>[\\S\\s]*)

下面是测试的代码。
[mw_shl_code=java,true]                String  pattern = "(?<g1>[\\S\\s]*)\\|(?<g2>\\S+)\\|(?<g3>[\\S\\s]*)\\|(?<g4>[\\S\\s]*)";
                String str = "2017-08-02 13:10:19.094|HSFBizProcessor-5-thread-155|DEBUG|setMember begin typeId=[qps_push_waybill], key=[9891003749887], expireTime=[15552000]";
                StringBuffer buf = new StringBuffer("");
                Pattern r = Pattern.compile(pattern);
                Matcher m = r.matcher(str);
               
                if(m.find()){
                        System.err.println("true  ");
                        System.err.println(m.group("g1") + "  ,  "+ m.group("g2") + "  ,  " + m.group("g3") + "  ,  " +m.group("g4") );
                        
                }[/mw_shl_code]
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条