扇入和扇出

通过使用命名目的地,您可以支持扇入和扇出用例。扇入用例是指多个源都将数据发送到同一个命名目的地,如下例所示

s3 > :data
ftp > :data
http > :data

前面的示例将来自 Amazon S3、FTP 和 HTTP 源的数据负载定向到同一个命名目的地,称为data。然后,使用以下 DSL 表达式创建的另一个流会将来自这三个源的所有数据发送到文件接收器

:data > file

下图显示了扇入的图形表示

Fan-in

扇出用例是指您根据仅在运行时才知道的某些信息来确定流的目的地。在这种情况下,您可以使用路由器应用程序来指定如何将传入消息定向到 N 个命名目的地之一。

还有一个很好的视频展示了扇入和扇出行为。