amazon-web-services - aws Kinesis steam 可以用作优先级队列吗？

Question

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

谢谢你，杰迪普

标签： amazon-web-servicesamazon-kinesis

Answer 1

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

不幸的是，SQS 也不支持优先级队列，但是那个 SO 线程有一些替代方案的建议。