将 AWS Kinesis 与 wso2cep 连接的最佳实践是什么
What is the best practice to connect AWS Kinesis with wso2cep
我们目前使用 kinesis 接收 json 格式的近乎实时的事件数据，并将其加载到 s3 和 Redshift。
为了在线触发基于聚合的复杂事件，我们计划使用 wso2 cep，并使用 Storm 来实现可扩展性。
此处的最佳做法是什么？ storm 应该与 kinesis 相关吗？
当您使用具有 Storm 可扩展性的 WSO2 CEP 时，您应该将事件发送到 WSO2 CEP，后者会将事件发布到 Storm 并取回结果。基本上 Storm 部署将是透明的，您将通过 CEP 发送和接收事件。 AFAIU 您可以通过 Kinesis 中的消费者使用所需的方法将事件发送到 WSO2 CEP。 CEP 支持很多 receiver types.
您可以参考this to understand more about deployment architecture and configurations. This guide explains on how to create an execution plan and deploy in storm. To try out the functionality you can follow this示例。
此致
我们目前使用 kinesis 接收 json 格式的近乎实时的事件数据，并将其加载到 s3 和 Redshift。
为了在线触发基于聚合的复杂事件，我们计划使用 wso2 cep，并使用 Storm 来实现可扩展性。
此处的最佳做法是什么？ storm 应该与 kinesis 相关吗？
当您使用具有 Storm 可扩展性的 WSO2 CEP 时，您应该将事件发送到 WSO2 CEP，后者会将事件发布到 Storm 并取回结果。基本上 Storm 部署将是透明的，您将通过 CEP 发送和接收事件。 AFAIU 您可以通过 Kinesis 中的消费者使用所需的方法将事件发送到 WSO2 CEP。 CEP 支持很多 receiver types.
您可以参考this to understand more about deployment architecture and configurations. This guide explains on how to create an execution plan and deploy in storm. To try out the functionality you can follow this示例。
此致