如何将 post 消息从 spring 云数据流任务发送到目的地?

How to post a message to a destination from a spring cloud data flow task?

是否有 correct/preferred 使用 Spring 云数据流将消息从任务发送到目标的方法?

我们有一个带有目的地的现有流,并且希望计划任务也通过其中一个目的地将消息馈送到流中。

我们目前考虑的选项:

  1. 使用 http 源应用程序创建一个新流以馈送到目标,然后在任务中使用 rest 模板将数据 post 发送到 http 源。对这种方法的担忧是,如果重新部署 stream/pod,http 源的 IP 地址可能是短暂的。
  2. 在任务中手动配置rabbit,将消息直接发送到目的地(exchange)。对这种方法的担忧是感觉有点脏,并且可能滥用数据 flow/streams 正在使用的底层消息系统。

我没有发现 #2 有任何实际问题,但您也可以配置输出绑定并使用 StreamBridge 发送给它。

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