0

我想了解siddhi中的“dos”和“dont dos”。我看到了 DB 连接器以及使用来自 DB 的数据丰富流事件的可能性（比如说 cassandra 连接器）。

示例：

@primaryKey('id')
@store(type = 'rdbms', datasource = 'WSO2_TEST_DB')
define table BuyerInfoTable (id string, name string, address string, email string);

@info(name = 'EnrichBuyerInformation')
from ShipmentInfoStream as s join BuyerInfoTable as b
    on s.buyerId == b.id
select s.orderId, b.name, b.address, b.email, s.shipmentType
insert into ShipmentAndBuyerInfoStream;

我是否理解正确，这种方法意味着在ShipmentInfoStream上的每个传入事件上都会对数据库进行选择查询上的每个传入事件对数据库进行选择查询？如果是的话 - 这对我来说听起来像是“不要做” - 特别是如果我们谈论的是 100k 事件/秒。

还是我以错误的方式理解架构？

4

1 回答 1

0

是的，你是对的。根据上面的查询，当 ShipmentInfoStream 中有事件到达时，就会有一个 DB 查询，获取输出并进一步处理。

但是，可以通过各种方式改进此操作。

  • 如果数据库表只包含有限的值（并且没有被外部用户更改），那么您可以预加载这些事件，保留在内存中的事件存储中并处理它们。

  • 您可以使用缓存来提高性能。检查https://siddhi.io/en/next/docs/query-guide/#store中的“内存缓存”部分...

于 2019-07-05T06:05:01.590 回答