3

我有一个 postgres 黑名单表,我想加载这个表并使用 WSO2 DAS 的事件表进行连接。

但它不允许我在查询中使用黑名单吃。

这是我的示例代码:

@From(eventtable='rdbms', jdbc.url='jdbc:postgresql://localhost:5432/pruebabg', username='postgres', password='Easysoft16', driver.name='org.postgresql.Driver', table.name='Trazablack')
define table Trazablack (sensorValue double);

@From(eventtable='rdbms', jdbc.url='jdbc:postgresql://localhost:5432/pruebabg', username='postgres', password='Easysoft16', driver.name='org.postgresql.Driver', table.name='Trazawhite')
define table TrazaExtend (Trazawhite double);

from Trazablack
select *
insert into TrazaFiltrada;

这是错误:

“ID 为“Trazablack”的流/表定义尚未在执行计划“ExecutionPlan”中定义”

这是可能的?

4

1 回答 1

2

您无法在 Siddhi 中读取这样的表,它应该通过连接查询(使用传入事件触发)来完成。如果没有传入的事件流,就无法触发查询。

如果您不想提供任何外部事件来触发此查询,您可以在 Siddhi 中使用触发器(有关更多信息,请参阅此文档)。

每 5 分钟触发一次的示例查询:

define trigger FiveMinTriggerStream at every 5 min;

from FiveMinTriggerStream join Trazablack as t
select t.sensorValue as sensorValue
insert into TrazaFiltrada;
于 2016-05-25T06:09:27.310 回答