tasklaunchrequest-Transformation ignoriert die Nutzlast

Question

ich einen Strom haben, bestehend aus

Quelle | ProzessorP1 | ProzessorP2 | ProzessorP3 | ProzessorP4 | Sink

I ProcessorP1 als mein tasklaunchrequest-transform Prozessor bin. Ich verwende dies, um eine Aufgabe über task-launcher zu starten. Jetzt muss ich meine Payload von ProcessorP1 zu ProcessorP2 weiterleiten und auch die Aufgabe aufrufen; Die TaskLaunchRequest hat keine Möglichkeit, die Nutzlast zu tragen, da sie ignoriert wird.

https://github.com/spring-cloud-stream-app-starters/tasklaunchrequest-transform/blob/master/spring-cloud-starter-stream-processor-tasklaunchrequest-transform/README.adoc

Gibt es eine Möglichkeit auf der Nutzlast zum nächsten Prozessor in meinem Stream zu übergeben?

Answer 1

Da die tasklaunchrequest-transform-processor die eingehende Nutzlast ignoriert, müssen Sie, um das zu erreichen, was Sie suchen, den Prozessor anpassen, dh Sie müssen die Logik im Prozessor so ändern, dass er die eingehenden Nutzdaten und Attaches annimmt die TaskLaunchRequest irgendwie. Wenn die eingehende Payload ein String-Typ ist, können Sie das als Umgebungseigenschaft oder als Befehlszeilenarg in TaskLaunchRequest hinzufügen. Geben Sie diese modifizierte Anforderung dann im Wesentlichen über den Stream weiter. Im Grunde müssen Sie Ihren ProzessorP1 durch einen benutzerdefinierten takslaunchrequest-transform-processor ersetzen, der dies tut.

Sehen Sie hier einige Richtlinien für die aus den Box-Anwendungen Patchen: https://docs.spring.io/spring-cloud-stream-app-starters/docs/current/reference/htmlsingle/#_patching_pre_built_applications oder neue zu schaffen: https://docs.spring.io/spring-cloud-stream-app-starters/docs/current/reference/htmlsingle/#_creating_new_stream_application_starters_and_generating_artifacts