【问题标题】:How to analyze event sequences with Apache Flink to trigger actions?如何使用 Apache Flink 分析事件序列以触发操作?
【发布时间】:2017-08-07 04:15:09
【问题描述】:

我想使用 Apache Flink 实时分析事件流并根据以下条件触发操作:

  • 事件窗口,发生特定事件(“如果事件 A 和事件 B 在 30 秒内发生 -> 触发动作”)
  • 事件序列,其中发生了特定事件(“如果事件 A 发生在事件 B 之后,事件 C 发生在事件 B 之后 -> 触发动作”)
  • 两者的结合

我知道 flink 能够通过 stream.windowAll(...) 进行窗口化,但我不确定如何反映事件序列。

如何实现这样的事件序列检测?

【问题讨论】:

    标签: events real-time apache-flink flink-streaming


    【解决方案1】:

    FlinkCEP (https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html) 是一个 CEP(复杂事件处理)库,能够以更抽象的方式处理事件流,并且(除其他外)涵盖了您所描述的场景。

    【讨论】:

    • 很好,没看到。谢谢!
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2013-10-05
    • 1970-01-01
    • 2021-11-20
    • 1970-01-01
    • 1970-01-01
    • 2016-05-28
    相关资源
    最近更新 更多