我可以用 table 事件 WSO2 加载一个列表吗
Can I load a list white with table event WSO2
我有一个 postgres 黑名单 table,我想加载这个 table 并使用 WSO2 DAS 的事件 table 进行连接。
但它不允许我在查询中使用黑名单 eat from。
这是我的示例代码:
@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;
这是错误:
"Stream/table definition with ID 'Trazablack' has not been defined in execution plan "执行计划""
可能吗?
你不能像 Siddhi 中那样读 table,它应该用 join query 来完成(使用传入事件触发)。没有传入事件流,就无法触发查询。
如果您不想提供任何外部事件来触发此查询,您可以在 Siddhi 中使用触发器(有关详细信息,请参阅 this doc)。
每 5 分钟触发的示例查询:
define trigger FiveMinTriggerStream at every 5 min;
from FiveMinTriggerStream join Trazablack as t
select t.sensorValue as sensorValue
insert into TrazaFiltrada;
我有一个 postgres 黑名单 table,我想加载这个 table 并使用 WSO2 DAS 的事件 table 进行连接。
但它不允许我在查询中使用黑名单 eat from。
这是我的示例代码:
@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;
这是错误:
"Stream/table definition with ID 'Trazablack' has not been defined in execution plan "执行计划""
可能吗?
你不能像 Siddhi 中那样读 table,它应该用 join query 来完成(使用传入事件触发)。没有传入事件流,就无法触发查询。
如果您不想提供任何外部事件来触发此查询,您可以在 Siddhi 中使用触发器(有关详细信息,请参阅 this doc)。
每 5 分钟触发的示例查询:
define trigger FiveMinTriggerStream at every 5 min;
from FiveMinTriggerStream join Trazablack as t
select t.sensorValue as sensorValue
insert into TrazaFiltrada;