我正在尝试确定是否有一种方法可以优先考虑优先从流中首先获取的数据，而不管它何时放入流中。例如，我正在将两种类型的数据A和B写入流；我希望即使将类型B首先写入流中，类型A的数据也始终要领先于类型B。 （数据正在流式传输到AWS Lambda以便执行）。我在AWS网站上找不到有关优先级的任何信息。我唯一想到的解决方案是设置两个流，并更改它们的读取限制。如果在Kinesis中有优先级队列/流之类的东西，请给我一些信息。
谢谢，Jaydeep
不，Kinesis无法做到这一点。您可以设置PartitionKey或ExplicitHashKey来使某些消息进入某些分片，其中某些分片的处理速度更快/更紧急。不过，情况并不完全相同。
SQS doesn't support priority queues either, unfortunately，但是该SO线程对替代方法有一些建议。