Ausführungsplan Vorlagen in Wso2 CEP

Question

Ich verwende WSO2 CEP für die Verarbeitung der Ereignisse aus einem Kafka-Thema. Ich möchte dies auf mehrere kafka-Themen verallgemeinern, die Protokolle in einem ähnlichen Format speichern, d. H. Jede Partition jedes Themas speichert Daten einer bestimmten Person.

Das Szenario ist wie folgt; Ein Thema gibt eine Supergruppe an, in der jede Partition eine Person in dieser Gruppe ist. In jeder Partition existieren JSON-formatierte Datenpunkte {Banktransaktionsinformationen (Transaktionszeit, Kredit/Debit, Betrag) usw. dieser Person.

Ich möchte in der Lage sein, die Daten so zu zerlegen, dass ich schließlich Ströme von Betrag von der Person gutgeschrieben/abgebucht bekomme, dh nach dem ersten (Ebene der) Ausführungsplan werden verschiedene Personendaten in einzelne Datenströme aufgeteilt durch einen zweiten Ausführungsplan, der jeden Strom weiter in (Zeitstempel, Kredit/Soll) Strom und (Zeitstempel, Betrag) Strom unterbricht.

Naive Weise, dies zu erreichen, ist ein Programm zu schreiben, das Ausführungspläne (Siddhisql-Datei), Ereignisströme (JSON-Dateien), Ereignisempfänger und Herausgeber (XML-Dateien) programmatisch für Sie schreibt. Mit steigender Anzahl der Themen steigt jedoch die Anzahl dieser Dateien.

Gibt es irgendeine Möglichkeit, dies zu tun (zumindest Erstellung von Ausführungsplänen)?

Answer 1

Sie können Ausführungsvorlagen erstellen, in denen Sie eine Ausführungsplanvorlage definieren und die erforderlichen Datenströme für die Vorlage einschließen können. Wenn Sie die Vorlage definieren, können Sie Parameter definieren, die später mit Istwerten konfiguriert werden können. In der aktuellen Version unterstützt CEP nicht die Einbindung von Empfängern und Publishern für die Vorlage.

Bitte beachten Sie die WSO2-Dokumentation n Creating Execution Templates. Um mehr über die Template-Struktur zu erfahren, beziehen Sie sich bitte auf this blog post.