我对siddhi-cep有点反感，因为它有siddhi查询语言，但它使用storm进行分布式处理，wso2提供了一个web界面/ Jmeter 板来创建和部署应用程序。我认为这会减少我增强/使用某些功能的独立性。另一方面，flink似乎是个不错的选择，但它需要很多代码来实现甚至简单的逻辑。有没有比这些更好的选择，我很困惑
pengsaosao1#
你说的不那么独立是什么意思？您可以使用siddhi 4.x[1]，而不依赖于storm，通过使用其源和接收器功能，使用tcp、kafka、http等从一个示例接收和发送消息到另一个示例。wso2 stream processor还使用新版本的siddhi及其编辑器，您可以模拟和调试事件。更新：从4.1开始[wso2 stream processor][2]可以在kafka上以完全分布式模式运行。看到了吗https://docs.wso2.com/display/sp4xx/fully+distributed+deployment.[1] https://wso2.github.io/siddhi/[2] https://wso2.com/analytics
0h4hbjxa2#
我会做一个测试…在每个系统中创建10个查询…类似。。。。
select * from SomeEvent where value = 1 select * from SomeEvent where value = 2 ... select * from SomeEvent where value = 9 select * from SomeEvent where value = 10
这样做的目的是了解创建查询有多容易，api或deploy步骤如何工作，以及性能如何随查询数的变化而变化。
2条答案
按热度按时间pengsaosao1#
你说的不那么独立是什么意思？您可以使用siddhi 4.x[1]，而不依赖于storm，通过使用其源和接收器功能，使用tcp、kafka、http等从一个示例接收和发送消息到另一个示例。wso2 stream processor还使用新版本的siddhi及其编辑器，您可以模拟和调试事件。
更新：从4.1开始[wso2 stream processor][2]可以在kafka上以完全分布式模式运行。看到了吗https://docs.wso2.com/display/sp4xx/fully+distributed+deployment.
[1] https://wso2.github.io/siddhi/
[2] https://wso2.com/analytics
0h4hbjxa2#
我会做一个测试…在每个系统中创建10个查询…类似。。。。
这样做的目的是了解创建查询有多容易，api或deploy步骤如何工作，以及性能如何随查询数的变化而变化。