Re: CEP use case ?
If the rules can be implemented by examining events in isolation (e.g., temperature > 25), then the DataStream API is all you need. But if you want rules that are looking for temporal patterns that play across multiple events, then CEP or MATCH_RECOGNIZE (part of Flink SQL) will simplify the implementation. An example of a more complex rule would be something like "the temperature rose by more than 5 degrees during an hour". Note that both CEP and MATCH_RECOGZNIZE are designed for situations in which the rules are known at compile time. Best, David On Fri, Jul 17, 2020 at 2:05 AM Aissa Elaffani wrote: > Hello Guys, > I have some sensors generating some data about their (température, > humidity, positioning , ...) and I want to apply some rules (simple > conditions, if température>25, ...), in order to define if the sensor is on > "Normal" status or "Alerte" status. Do i need to use flink CEP, or just the > DataStream Api is suffisant to define the status of each sensor. > Sorry for disturbing you ! I hope someone can help me with that. > Thank you guys. > Best > Aissa >
CEP use case ?
Hello Guys, I have some sensors generating some data about their (température, humidity, positioning , ...) and I want to apply some rules (simple conditions, if température>25, ...), in order to define if the sensor is on "Normal" status or "Alerte" status. Do i need to use flink CEP, or just the DataStream Api is suffisant to define the status of each sensor. Sorry for disturbing you ! I hope someone can help me with that. Thank you guys. Best Aissa
Re: CEP use case !
Hi Aissa, Flink CEP is an api that processes multi-event matching with a pattern, like (START MIDDLE+ END). If you can calculate the "sensor_status" by one record, I think Flink DataStream API / Table & SQL API could satisfy your requirement already. Aissa Elaffani 于2020年6月25日周四 下午11:35写道: > Hello Guys, > I am asking if the CEP Api can resolve my use case. Actually, I have a lot > of sensors generating some data, and I want to apply a rules engine on > those sensor's data,in order to define a "sensor_status" if it is Normal or > Alert or warning.for each record I want to apply some conditions (if > temperature>15, humidity>...) and then defne the status of the sensor, if > it is in Nomarl status, or Alerte status ... > And I am wondering if CEP Api can help me achieve that. > Thank you guys for your time ! > Best, > AISSA > -- Best, Benchao Li
CEP use case !
Hello Guys, I am asking if the CEP Api can resolve my use case. Actually, I have a lot of sensors generating some data, and I want to apply a rules engine on those sensor's data,in order to define a "sensor_status" if it is Normal or Alert or warning.for each record I want to apply some conditions (if temperature>15, humidity>...) and then defne the status of the sensor, if it is in Nomarl status, or Alerte status ... And I am wondering if CEP Api can help me achieve that. Thank you guys for your time ! Best, AISSA