2016-06-01 9 views
0

Wir können Dataweave über ein Streaming-Objekt [refer] betreiben. Ich habe ein Szenario, in dem ich 2 separate Dateien streamen und den Inhalt zusammenführen muss, um es in eine Datei zu schreiben. Was ist der effizienteste Weg, dies zu tun ... Ich vermeide Verwendung von async Umfang, da dies mehr Abhängigkeit von Prozessor erzeugtStreaming in Mule

+0

Mit merge, meinst du nur kombinieren zwei Inhalte oder würden Sie auch Transformationen tun? –

+0

Ja, ich möchte sie transformieren und kombinieren. – scorpion

+0

Hast du bisher irgendwelche Methoden in Maultieren versucht? –

Antwort

0

Streaming ist in der Regel voraus nur so ist es gut mit einzelnen gestreamt funktioniert Eingang. Selbst wenn Sie eine andere gestreamte Eingabe in die Flow-Variable lesen, kann es schwierig sein, Transformationen für sie gemeinsam zu verwenden. Haben Sie versucht, einen Stream als Payload und andere als Flow-Variable zu lesen und dann in DataWeave zu arbeiten? Übrigens, werden Sie eine Transformation auf Datensatzebene durchführen?

Bezieht sich die Aufzeichnung von Datei 1 auf Datensätze von Datei 2 durch einige allgemeine Daten ODER sind sie unabhängige Datensätze mit denselben Metadatendefinitionen?

Wenn beide nicht verwandt sind, können Sie zuerst beide Dateien zu einem zusammenführen (Dateiausgang mit append = true) und dann die kombinierte Datei streamen und an der Umwandlung arbeiten.

Also kommt es auf die Transformation an :)