{"id":748,"date":"2016-07-18T12:48:31","date_gmt":"2016-07-18T10:48:31","guid":{"rendered":"http:\/\/www.rocworks.at\/wordpress\/?p=748"},"modified":"2016-08-03T08:33:45","modified_gmt":"2016-08-03T06:33:45","slug":"streaming-complex-event-processing-cep-eplcql-with-wincc-oa","status":"publish","type":"post","link":"https:\/\/www.rocworks.at\/wordpress\/?p=748","title":{"rendered":"Streaming & Complex Event Processing (CEP) & EPL\/CQL with WinCC OA…"},"content":{"rendered":"

Complex Event Processing (CEP) and event series analysis are used for detecting situations among events. EsperTech provides the Event Processing Language (EPL) designed for concisely expressing situations and fast execution against both historical and currently-arriving events (Espertech.com<\/a>).<\/p>\n

The Esper EPL is quite powerful \u2013 details can be found in the Esper documentation<\/a>. Found also some slides <\/a>about Esper. The EPL is a CQL (continuous query language), after a statement is created it is running coninously and\u00a0results are streamed\u00a0to\u00a0listeners – in this prototype\u00a0a listener is sending\u00a0the results back to WinCC OA datapoints.<\/p>\n

A WinCCOA API-Frontend-Manager gathers all\u00a0value changes from WinCC OA and publishes it by ZeroMQ. The\u00a0WinCC OA CEP Manager, with the open source Esper-Engine, subscribes to the Frontend-Manager to get the value changes. The advantage is that many subscribers can be connected to the Frontend-Manager, without increasing the load on the WinCC OA system (based on the ideas from CERN).<\/span><\/p>\n

With the WinCC OA CEP Manager we can define\u00a0EPL \/ CQL statements in WinCC OA and the result streams are passed back to WinCC OA on datapoints, where the results can be processed further.<\/p>\n

Some simple EPL examples:<\/p>\n

Calculate 5 minute average values<\/strong> with intermediate results every 1 minute:<\/p>\n

select avg(value), min(value), max(value) \r\nfrom event(tag='System1:Meter_Input.Watt').win:time(5 min) \r\noutput snapshot at (*\/1, *, *, *, *)<\/pre>\n
With pattern matching complex event sequences<\/strong> can be observed with EPL. A simple example is: detect if datapoint B is set after datapoint A (A->B), and its value is higher than the value of A.<\/p>\n
select a.value, b.value\r\nfrom pattern [a=Event(tag='System1:Analog1.Input') -> every b=Event(tag='System1:ExampleDP_Trend1.' and b.value>a.value)]<\/pre>\n
Get a notification when a datapoint is changing more than<\/strong> 100 times within 10 seconds:<\/p>\n
select tag, count(value) \r\nfrom Event.win:time_batch(10 sec) \r\ngroup by tag having count(*) > 100<\/pre>\n
Get a notification when a datapoint changes and there is no following value<\/strong> change within the next 10 seconds. For example: if meters are normally changing every 5 seconds, possible broken meters\/interfaces can be detected with EPL:<\/p>\n
select a.tag, count(*) from pattern \r\n[every a=Event -> (timer:interval(10 sec) and not Event(tag=a.tag))] \r\ngroup by a.tag<\/pre>\n
Other examples can be found here<\/a>.<\/p>\n
Attached is a screenshot of a simple panel where EPL statements can be defined and observed.<\/p>\n
\"WinCCOA<\/a><\/p>\n
Other examples for CEP with Esper:\u00a0http:\/\/www.adrianmilne.com\/complex-event-processing-made-easy\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
Complex Event Processing (CEP) and event series analysis are used for detecting situations among events. EsperTech provides the Event Processing Language (EPL) designed for concisely expressing situations and fast execution against both historical and currently-arriving events (Espertech.com). The Esper EPL is quite powerful \u2013 details can be found in the Esper documentation. Found also some … Continue reading Streaming & Complex Event Processing (CEP) & EPL\/CQL with WinCC OA…<\/span> →<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[29,3],"tags":[],"class_list":["post-748","post","type-post","status-publish","format-standard","hentry","category-bigdatanosql","category-wincc-oa"],"_links":{"self":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/748","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=748"}],"version-history":[{"count":7,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/748\/revisions"}],"predecessor-version":[{"id":760,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/748\/revisions\/760"}],"wp:attachment":[{"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=748"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=748"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.rocworks.at\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=748"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}