如何从Spring Cloud数据流任务向目的地发布消息?

问题描述

是否存在使用Spring Cloud Data Flow将消息从任务发送到目标的正确/首选方法

我们已有一个带有目的地的流,并且希望预定任务也通过一个目的地向流中馈送消息。

到目前为止我们已经考虑过的选项:

  1. 使用http源应用程序创建新流以馈入目标,然后在任务中使用rest模板将数据发布到http源。与这种方法有关的是,如果重新部署stream / pod,则http源的ip地址可以是临时的。
  2. 在任务中手动配置Rabbit,将消息直接发送到目的地(交换)。与这种方法有关的是,感觉有点脏,并且可能滥用了数据流/流正在使用的基础消息传递系统。

解决方法

我看不到#2的任何实际问题,但是您也可以配置输出绑定并使用StreamBridge发送给它。

Sending arbitrary data to an output (e.g. Foreign event-driven sources)