2016-05-24 6 views
3

У меня есть таблица postgres blacklist, я хочу загрузить эту таблицу и выполнить соединение, используя таблицу событий WSO2 DAS.Могу ли я загрузить белый список с событием таблицы WSO2

но он не позволяет мне использовать черный список в запросе.

Это мой код образца:

@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/определение таблицы с 'Trazablack Ид не был определен в плане выполнения "ExecutionPlan" "

это возможно?

ответ

2

Вы не можете прочитать таблицу, подобную таблице в Сиддхи, это должно быть сделано с помощью join query (с помощью входящего события). Без входящего потока событий невозможно инициировать запрос.

Если вы не хотите передавать какие-либо внешние события для запуска этого запроса, вы можете использовать триггер в Сиддхи (для получения дополнительной информации см. this doc).

Пример запроса, который срабатывает каждые 5 минут:

define trigger FiveMinTriggerStream at every 5 min; 

from FiveMinTriggerStream join Trazablack as t 
select t.sensorValue as sensorValue 
insert into TrazaFiltrada; 
+0

Идеальное решение. –