cep

0зной

1ответ

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

Позвольте мне объяснить это немного больше. У меня есть этот Cep конфигурации: { "host":"http://localhost:1028", //Cepheus CEP "in":[ { "id":"A.*", "type":"Pevent", "i

0зной

1ответ

Регистрация с триггером в сиддхи

У меня есть вопрос. Я использую DAS 3.0.1. Trazablack - стол postgres. Я не могу сделать присоединиться к событию Trazafiltrada, это было создать с помощью следующего кода: define trigger FiveMinTrigg

1зной

1ответ

время работы триггера в Сиддхи

Я хочу, чтобы прочитать таблицу Postgres из сиддхи, и я с помощью триггера: @From(eventtable='rdbms', jdbc.url='jdbc:postgresql://localhost:5432/pruebabg', username='postgres', password='Easysoft16',

0зной

1ответ

Siddhi CEP - события, которые не были объединены в скользящее окно

У меня есть два потока, streamA и streamB. Каждый из streamA имеет идентификатор и соответствующее событие в streamB будет иметь одинаковый идентификатор. Я хочу знать от streamA, какие идентификаторы

0зной

2ответ

Веб-сервисы в Сиддхи

У меня есть веб-службы (REST). Я хочу называть WS каждый раз, когда событие приходит в мой поток. Мне нужно создать расширение Сиддхи и вызвать веб-сервис из java? Если мне нужно java для вызова веб-с

0зной

1ответ

Служба REST wso2 DAS или CEP

Могу ли я сделать вызов службы REST, который использует параметр другого входного потока типа HTTP из сиддхи? Например: У меня есть входной поток sensorStream: @Import('org.wso2.event.sensor.stream:1.

1зной

1ответ

«str содержит» Функция SIDDHI

У меня есть queshion. Могу ли я сделать запрос и использовать функцию «str: contains» с двумя событиями. Например заменить: from DSBStream[(str:contains(correlation_phr_incident_detail, '0.0.0.0')==FA

0зной

2ответ

JAR для простирается сиддхи

Я хочу продлить сиддхи, мили код Java является: package org.wso2.siddhi.extension.fraude; import org.wso2.siddhi.core.config.ExecutionPlanContext; import org.wso2.siddhi.core.executor.ExpressionExe