Как правильно настроить cepheus cep для пересчета атрибута каждый час?

Question

Позвольте мне объяснить это немного больше. У меня есть этот Cep конфигурации:

{ 
    "host":"http://localhost:1028", //Cepheus CEP 
    "in":[ 
    { 
     "id":"A.*", 
     "type":"Pevent", 
     "isPattern":true, 
     "providers":[ 
     "http://localhost:1027" //Cepheus Broker 
     ], 
     "attributes":[ 
     { "name":"idEvent", "type":"string" }, 
     { "name":"endDate", "type":"date" } 
     ] 
    } 
    ], 
    "out":[ 
    { 
     "id":"A", 
     "type":"Event", 
     "brokers":[ 
     { 
      "url":"http://localhost:1026" //orion 
     } 
     ], 
     "attributes":[ 
     { "name":"expired", "type":"int" } 
     ] 
    } 
    ], 
    "statements":[ 
    "INSERT INTO Event SELECT idEvent as id, case when endDate<current_timestamp() then 1 else 0 end as expired FROM Pevent OUTPUT all" 
    ] 
} 

Эта конфигурация, когда новый объект aded или изменения в контексте Цефей брокера, он оповещает Цефей КЭП и КЭП высчитывает, если объект истек или нет и отправить результат в orion.This работает нормально, без проблем.

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

Большое спасибо.

Answer 1

Вам нужно второе правило для обнаружения истекшего события.

Вы можете использовать Esper Patterns, чтобы обнаружить, что событие имеет не произошло в течение определенного периода времени:

SELECT e.id as id, 1 as expired FROM pattern[every e=Pevent -> (timer:interval(1 hour) and not Pevent(id = e.id)]