Вопросы по теме 'siddhi'
Сиддхи-запрос для обнаружения входа в геозону
Я пытаюсь заставить Siddhi запускать события всякий раз, когда он обнаруживает, что рейс вошел в геозону, но не могу точно определить правильный запрос для этого.
У меня есть следующее определение входного потока:
define stream...
259 просмотров
schedule
15.07.2022
Производительность запроса Siddhi CEP Pattern
Использование шаблонного запроса автономной библиотеки Siddhi CEP для периодического обнаружения отсутствия события каждые 5 минут на 10 тыс. Событий. Наблюдающая память постепенно увеличивается. Любая помощь в этом, почему это происходит?
Объем...
421 просмотров
schedule
04.11.2023
Обратный вызов после завершения обработки запроса в Siddhi
Я пишу небольшую программу CEP, используя Siddhi . Я могу добавить обратный вызов всякий раз, когда заданный фильтр выводит такие данные
executionPlanRuntime.addCallback("query1", new QueryCallback() {
@Override
public void...
199 просмотров
schedule
07.09.2023
Понимание типа запроса Window в Siddhi
Я пытаюсь реализовать базовое окно для входного потока в сиддхи. Это запрос окна
executionPlan = "" +
"define stream inputStream (height int); " +
"" +
"@info(name = 'query1') " +...
132 просмотров
schedule
28.07.2022
Тайм-менеджмент с сиддхи
Мне нужно сохранить белый список на 2 минуты, но мне нужно выполнить запрос (используя мой белый список) при поступлении нового потока. Я использую два потока со следующим кодом:
Мне нужно заряжать мой БЕЛЫЙ СПИСОК, который обновляется каждые две...
69 просмотров
schedule
18.06.2022
WSO2CEP: получение значения предыдущего события из потока в запросе сиддхи
Я использовал следующий siddhi query , чтобы получить количество событий в минуту; ts как отметка времени (строка) и ftp_requests как count (int).
from FTPInStream[command == 'USER']
select...
164 просмотров
schedule
31.03.2022
Siddhi QL: внешнее соединение таблицы в памяти с входным потоком
Я хочу непрерывно вычислять% протоколов, появляющихся в сетевом трафике, чтобы эти% постоянно обновлялись новыми событиями. Создается круговая диаграмма, которая обновляется процентами. Поскольку для расчета мне нужны как новые, так и предыдущие...
300 просмотров
schedule
30.03.2024
Siddhi Я не получаю ответа на совокупный запрос
У меня есть простой запрос, как это:
define stream myEventStream (userId string, price int);
define stream outputStream (avgPrice double, userId string);
@info(name = 'aQuery')
from myEventStream#window.time(5000)
select avg(price) as...
44 просмотров
schedule
11.06.2023
wso2 cep externalTime проблема
Согласно Руководству пользователя, я предполагаю, что окно externalTime (отметка времени, значение времени) должно хранить события только в диапазоне: от отметки времени до отметки времени + значение времени.
Например, в плане выполнения
from...
79 просмотров
schedule
20.05.2022
WSO2 CEP - запросы Siddhi сопоставляют координаты различных потоков событий
Я новичок в запросах WSO2 CEP и Siddhi. Я создал три разных потока событий, каждый из которых относится к определенному датчику, как показано на изображении ниже:
Каждый поток событий датчиков имеет широту и долготу датчика. Датчики...
348 просмотров
schedule
26.03.2022
Ошибка запроса WSO2CEP Siddhi с использованием гео в функции
Я использую расширение GEO внутри функции в плане выполнения. У меня есть несколько потоков событий, которые содержат информацию о датчиках, включая местоположение каждого датчика (в географических координатах). Кроме того, у меня есть многоугольник...
140 просмотров
schedule
29.07.2023
Мой запрос работает только в правильном порядке потоков в движке Siddhi CEP
Я хочу создать поток из 4 входных потоков. Например,
from s1[at1>0], s2[at2==2], s3[at3>1], s4[at4 is null]
select 'k' as res
insert into s5;
Первая проблема заключается в том, что если я попробую ввести события в другом порядке на...
128 просмотров
schedule
28.07.2022
Siddhi - выборка из таблиц событий, которые не обновляются в течение определенного времени
В запросе Siddhi я импортирую два потока S1 и S2. Если я получу в потоке S1, я вставлю в таблицу событий T1, а когда я получу в S2, я обновлю в таблице T1 на основе идентификатора, а также отправлю обновленные значения из таблицы в выходной поток O1....
150 просмотров
schedule
08.09.2023
Сиддхи 4.0 проверяет, не пришло ли событие
Я использую Stream Processor для получения событий, и мне нужно знать, что есть способ проверить, что какое-то событие пришло в течение указанного времени в окне? Допустим, мы хотим проверить, приходило ли это событие каждые 5 минут. Если это не...
94 просмотров
schedule
15.03.2022
WSO2 SP Siddhi xml-синтаксический анализ из wso2event
У меня есть входной поток как wso2event на wso2 SP, и он содержит метку времени и полезную нагрузку. Полезная нагрузка в формате xml. Как я могу разобрать эту полезную нагрузку на переменные? Я вижу этот документ...
250 просмотров
schedule
05.05.2024
Как обработать входящее событие и на основе поля в событии записать в разные потоки с помощью wso2?
Я пытаюсь использовать один поток, обрабатывать входящий формат json и записывать в разные потоки на основе атрибута в событии. Например, если входной поток состоит из чего-то вроде этого:
{ "event_type" : "temperature",
"json" : {...
98 просмотров
schedule
25.07.2022
В потоковом процессоре WSO2 учебник по обнаружению аномалии выдает исключение.
Я пытаюсь воспроизвести руководство «Обнаружение аномалий», приведенное в документации по потоковому процессору WSO2.
@App:name('SugarSyrupOutlierPredictionApp')
@source(type='http', receiver.url='http://localhost:5007/SugarSyrupEP', @map(type =...
119 просмотров
schedule
09.05.2024
Как решить ошибку "Ошибка при создании индексов для идентификатора таблицы" в siddhi?
Я пытаюсь сохранить события, которые соответствуют некоторым фильтрам, в эластичный индекс, но когда я устанавливаю таблицу хранилища, он говорит, что не может создать индекс для этой таблицы.
Я тестировал это в версиях продукта 4.3.0 и 4.4.0, но...
91 просмотров
schedule
18.08.2023
Можно ли отменить развертывание приложения WSO2 с помощью редактора?
Можно ли отменить развертывание потокового приложения siddhi/wso2 с помощью редактора браузера? Я вижу возможность развернуть приложение, но ничего не могу отменить
Мне удалось отменить развертывание вручную, зайдя в рабочий контейнер...
86 просмотров
schedule
15.09.2023
Siddhi Query от Redis
похоже, у меня проблема с запросом Сиддхи из Redis. Код ниже не выводит OutputStream. У меня есть ключ в имени Redis как fo1
"@store(type='redis', host='x.x.x.x', port='6379', table.name='RedisTable')" +
"@PrimaryKey('key')" +...
79 просмотров
schedule
22.06.2023
