amazon-web-services - 如何将 Kinesis 数据流合并为一个以进行 Kinesis 数据分析？

Question

我有多个 AWS kinesis 数据流/firehose，其中包含 CSV 格式的结构化数据。我需要使用运动数据分析对该数据进行分析。但是如何将多个流合并为一个呢？因为 Kinesis 数据分析仅从一个流获取数据。数据流可以存在于不同的区域。

问题: 如何将 Kinesis 数据流合并为一个以进行 Kinesis 数据分析？

Answer 1

我不知道 AWS 是否有任何“现成”产品可供您用来执行此操作，但如果您不介意编写一点代码，那么这非常简单。

1. 创建一个将成为“合并流”的 kinesis 流(两个源流的事件都将位于此处。)
2. 使用您选择的编程语言创建 lambda，并将触发器设置为要合并的 kinesis 流。
3. 对 lambda 进行编码，将其接收到的所有事件写入第 1 步中创建的流中。

生成的运动流应该包含您正在查找的合并数据，并可以使用它来进行分析。