来自AMQP背景，如果我有一个创建小部件的应用程序，我将为我的事件创建路由键，如widget.created和widget.updated。然后我可以让队列绑定到他们需要的事件。因此，如果我想在创建窗口小部件时执行某些操作，我将绑定到widget.created。
使用Kinesis流时是否有相同的效果？我可以看到两种可能的方式（为每个事件类型使用单独的流或运行查看每个事件的Lambda函数并决定要执行的操作）但是想知道我是否遗漏了某些内容。
最后，我认为SNS + SQS组合更像是替代AMQP而不是Kinesis。每个服务发布到它自己的SNS主题，然后我为每个消费者使用一个SQS队列，因此每个消息可以由不同的Lambda函数使用。
Kinesis很适合将大量数据推送给少数消费者（每个流最多5个），但我不希望这个限制在将来影响我。