wso2: cep: siddhi: как сделать время окон стойким

Question

В настоящее время мы тестируем сиддхи wso2 cep.

Мы должны иметь возможность перезагрузить серверный процесс wso2, не теряя данные, накопленные в окне (например, временное окно).

Есть ли способ сделать временные окна стойкими, чтобы сервер можно было перезапустить, не потеряв его состояние?

Нужно ли настраивать сервер для использования персистентности?

Или нам просто нужно адаптировать запрос и использовать таблицу событий?

Вот пример нашего запроса:

from every data= DataInStream[state == 1] -> 
    every event = EventInStream[event.no == data.no] within 24h 
     insert into duplicatesOutStream data.id as id 

Answer 1

Вы можете сделать СЕР сохраняться это состояние, позволяя снимки. Документация может быть found here. Но имейте в виду, что это будет сохраняться «все состояние» КЭП «периодически» (настраивается в минутах). Поскольку это выполняется только периодически, вы можете потерять последние несколько событий, которые были получены после последней операции моментального снимка. Если вы хотите, чтобы cep восстановился после сбоя, это самый простой вариант.

Помимо этого, нет другого способа сделать постоянное заданное окно. Но если вы хотите, вы можете написать свое собственное окно времени (documentation), которое сделает упорство и подключит его к CEP.

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