https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/libs/cep.html#%E5%8C%B9%E9%85%8D%E5%90%8E%E8%B7%B3%E8%BF%87%E7%AD%96%E7%95%A5


官方文档中 这个API 或许可以解决你的问题


| |
张义藤
|
|
[email protected]
|
签名由网易邮箱大师定制
在2021年5月10日 18:48,lp<[email protected]> 写道:
我有一个flinkCEP的程序,检测nginx日志,假如同一ip,60s内超过3次访问,则报警。
我访问了7次,代号为1~7
检测到了4组报警分别是
[/1, /2, /3]
[/2, /3, /4]
[/3, /4, /5]
[/4, /5, /6]

请问下,如果想之前已经参与过匹配的数据不再参与匹配,应该怎样做,比如其实我想得到两组报警:
[/1, /2, /3]
[/4, /5, /6]


如下是我检测的关键代码:
Pattern<NginxLogFormatDefault, NginxLogFormatDefault> pattern =
Pattern.<NginxLogFormatDefault>begin("start").times(3).within(Time.seconds(60));




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复