Можно ли контролировать время в Сиддхи Сеп

Question

В приведенном ниже примере время - это время процессора.Что я испытываю, так это то, что когда я запускаю временные ряды для целей бэк-теста, данные поступают по порядку, но гораздо быстрее, и последующая логика, основанная на временном окне, не будет правильной. Мой вопрос: - Идеальное решение для меня - это изменить Сиддивремя, используя временную метку прибытия события временного ряда.Возможно ли это сделать?- Если нет, то что предлагает исправить эту проблему.

from fooStream#window.timeBatch(10 sec)
select count() as count
insert into barStream;

Answer 1

Вы можете использовать siddhi externalTimeWindow [1] для ваших требований.

Для extenrnalTimewindow вы можете указать свою собственную временную метку, и время окна будет рассчитываться из предоставленной вами временной метки.

[1] https://wso2.github.io/siddhi/api/latest/#externaltime-window

Answer 2

Вы можете использовать externalTimeWindow [1], как упоминалось ранее.Тем не менее, то, что вы ищете, это playback [2].

В Сиддхи внутренне есть два TimestampGenerator с.А именно EventTimeBasedMillisTimestampGenerator и SystemCurrentTimeMillisTimestampGenerator.По умолчанию SystemCurrentTimeMillisTimestampGenerator будет использоваться с ядром Siddhi CEP.Но если вы используете аннотацию playback, она изменится на EventTimeBasedMillisTimestampGenerator.Если вы используете это, Сиддхи будет использовать метку времени наступающего события временного ряда в качестве времени двигателей CEP.

[1] https://wso2.github.io/siddhi/api/latest/#externaltime-window

[2] https://wso2.github.io/siddhi/documentation/siddhi-4.0/#appplayback

[3] https://github.com/wso2/siddhi/blob/master/modules/siddhi-core/src/test/java/org/wso2/siddhi/core/managment/PlaybackTestCase.java

Answer 3

возможно, для этого вы можете использовать функциональность Windows externalTime для Siddhi.

см. Документацию https://wso2.github.io/siddhi/api/latest/#externaltime-window