2017-07-27 84 views
0

我有3个作为输入源的mongodb集合(来自相同数据库)。目前我正在使用3个kinesis流来访问这些集合。我需要结合他们来分析他们。我可以使用Kinesis Analytics来做到这一点吗?因为我看不到选择多个流作为Kinesis Analytic应用程序的输入的选项。是否可以为Kinesis Analytics设置多个输入流?

回答

0

Kinesis Analytics不具备添加多个流媒体源和一个参考数据源的功能。

参见:http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html

+0

是的,它是(AWS运动队也确认)。你知道任何方式结合Kinesis溪流或任何方式来克服我的情况? – GihanDB

+0

由于Kinesis Analytics的限制文档 - “每个应用程序可以有一个流源和最多一个参考数据源。”我相信如果你指的是多个目的地 - 可以使用CLI/SDK来完成(不可能通过控制台)。来到你的用例,我不知道有任何直接的方法来做到这一点,但可能有潜在的解决方法。 – Pushpesh

+0

[1]您可以将推送数据发送到一个流,然后使用Kinesis Analytics InApp流来过滤记录/收集数据。 [2]添加另一个流(比方说AllCollectionsStream),同时将记录推送到流中在生产者中添加一个逻辑,将每条记录推送到单个流+ AllCollectionsStream – Pushpesh

相关问题