Flink之CEP案例分析-網絡攻擊檢測

假定一家雲服務提供商，有多個跨地區的數據中心，每一個數據中心會定時向監控中心上報其瞬時流量。code 咱們將檢測的結果分爲三個等級：對象 正常：流量在預設的正常範圍內； 警告：某數據中心在10秒內連續兩次上報的流量超過認定的正常值； 報警：某數據中心在30秒內連續兩次匹配警告； 首先，咱們構建source，這裏咱們選擇的是並行source，所以須要繼承RichParallelSourceFunct

>>阅读原文<<