aws Kinesis steam 可以用作优先级队列吗？

Question

我试图弄清楚是否有一种方法可以优先考虑首先从流中获取的数据，而不管它何时被放入流中。例如，我正在将两种类型的数据 A 和 B 写入流中；我希望 A 类型的数据始终领先于 B 类型，即使 B 类型首先写入流。 （数据正在流式传输到 AWS lambda 以供执行）。 我在 AWS 网站上找不到任何有关优先级的信息。我能想到的唯一解决方案是设置两个蒸汽并改变它们的读取限制。 如果 Kinesis 中有类似优先级队列/流的东西，请给我一些相关信息。

谢谢你， 杰迪普

Answer 1

不，Kinesis 无法做到这一点。您可以设置PartitionKey 或ExplicitHashKey 以使某些消息转到某些分片，其中某些分片的处理速度更快/更紧急。不过，这并不完全相同。

SQS doesn't support priority queues either, unfortunately，但是那个 SO 线程有一些替代建议。