Temporal Interval Event Support

Question

Ich will nur sicher wissen, ob WSO2 CEP-Engine Online in Allens 13 temporalen Operatoren und auch klarer definiert, die in diesem Artikel gefunden temporale Operatoren unterstützt gefunden:

https://docs.jboss.org/drools/release/6.2.0.CR4/drools-docs/html/DroolsComplexEventProcessingChapter.html#d0e10924

Selbst Wenn es keine Unterstützung oder Funktionalität für zeitliche Ereignisse gibt, sind sie ziemlich einfach zu codieren und sind auch effizient/leicht durch den Stream zu handhaben?

Ich muss mehrere XML-Dateien mit jeweils einem eigenen Stream verarbeiten, und jedes Ereignis hat einen Startpunkt und einen Endpunkt, und ich möchte diese Ereignisse kennzeichnen, wenn 2 oder mehr zu einem bestimmten Zeitpunkt auftreten.

Danke!

Answer 1

Obwohl es keine direkte Eins-zu-eins-Zuordnung zwischen der Abfragesprache des WSO2 CEP und der angegebenen Liste von Operatoren gibt, können diese relativ einfach implementiert werden. Die Abfragesprache von WSO2 CEP unterstützt Muster, Sequenzen, Filter, Fenster, Tabellen, Joins und Aggregationsfunktionen, die primitive Bausteine ​​zur Implementierung solcher Anforderungen sind. Daher können Sie alle diese temporalen Operatoren einfach implementieren, indem Sie eine Kombination von Mustern/Sequenzen/Filtern/Fenstern/Joins usw. zusammenstellen. Sehen Sie sich die Siddhi (zugrunde liegende CEP-Engine in WSO2 CEP) query language specification an, um sich ein Bild über die Abfragesprache zu machen .

Auch kommt es mit einer Anzahl von Ereignisempfängertypen, die viele häufig verwendete Transporte und Nachrichtenformate einschließlich XML und JSON unterstützen. Sie können mit xpath-Ausdrücken Daten aus einer XML-Datei extrahieren und das resultierende Ereignis zur Verarbeitung an die Engine übergeben. Informationen zum Datenempfang finden Sie unter this.

Darüber hinaus, wenn Ihr Anwendungsfall schriftlich Erweiterungen erfordert, WSO2 CEP hat ein extension mechanism, die benutzerdefinierten Funktionen geschrieben mit JavaScript/Scala und R.