命名目标
除了引用源应用程序或接收器应用程序之外,您还可以使用命名目标。命名目标对应于中间件代理(RabbitMQ、Kafka 等)中的特定目标名称。使用 |
符号时,应用程序将使用 Data Flow 服务器创建的消息传递中间件目标名称相互连接。与 Unix 类比,您可以使用小于号 (<
) 和大于号 (>
) 字符重定向标准输入和输出。要指定目标的名称,请在其前面加上冒号 (:
)。例如,以下流在 source
位置具有目标名称
stream create --definition ":myDestination > log" --name ingest_from_broker --deploy
以下流从代理中名为 myDestination
的目标接收消息,并将其连接到日志应用程序。您还可以创建其他流来使用来自同一命名目标的数据。
以下流在 sink
位置具有目标名称
stream create --definition "http > :myDestination" --name ingest_to_broker --deploy
您还可以在流中连接代理中的两个不同目标(位于源和接收器位置),如下例所示
stream create --definition ":destination1 > :destination2" --name bridge_destinations --deploy
在前面的流中,两个目标(destination1
和 destination2
)都位于代理中。消息通过连接它们的 bridge
应用程序从源目标流向接收器目标。