amazon-web-services - 加入 Ki​​nesis Streams

Question

我有两个 Kinesis 流，我想创建第三个流，它是这两个流的交集。我的目标是让流处理器响应生成的第三个流上的事件，而无需编写执行此交集的使用者。

流 a上的记录将是：

{
    "customer_id": 3,
    "first_name":"Marcy",
    "last_name":"Shurtleff"
}

流 b上的记录将是：

{
    "payment_id": 10001,
    "customer_id": 1,
    "amount":234.56,
    "date":"2018-09-07T10:25:43.511Z"

}

我想执行一个连接（就像我可以在 KSQL 和 Kafka 中一样），它将流a.customer_id连接到流b.customer_id导致：

{
    "customer_id": 3,
    "first_name":"Marcy",
    "last_name":"Shurtleff",
    "payment_id": 10001,
    "amount":234.56,
    "date":"2018-09-07T10:25:43.511Z"
}

（或我选择的任何类似 sql 的投影）。

我知道 Kafka 和 KSQL 可以做到这一点，但 Kinesis 可以吗？

Kinesis Data Analytics 无济于事，因为您不能在该产品中使用多个流作为数据源，并且您只能对“应用程序内”流执行联接。

标签： amazon-web-servicesjoinamazon-kinesis