Вопросы по теме 'siddhi'
Проблема с фильтром сиддхи WSO2 CEP
Я пытаюсь использовать язык запросов сиддхи, но, похоже, я злоупотребляю им.
У меня есть несколько событий со следующим streamdef:
{ 'name':'eu.ima.stat.events', 'version':'1.1.0', 'nickName': 'Flux event Information', 'description':...
316 просмотров
schedule
28.08.2022
О поиске паттернов сиддхи
Имеет ли siddhi ( http://siddhi-cep.blogspot.com/ ) / WSO2 возможность работать над запросом, похожим на
1) 5 ошибок с последующим успехом
2) 5 ошибок, за которыми следуют 5 фатальных, за которыми следует 1 успех...
801 просмотров
schedule
28.05.2022
О написании пользовательского OutputAttributeProcessor
У меня есть несколько вопросов о написании пользовательского OutputAttributeProcessor. Я использую WSO2 CEP 2.1.0 и сиддхи 1.1.0.
Я хочу создать собственный OutputAttributeProcessor, поэтому я создаю два класса Java: TestFactory реализует...
85 просмотров
schedule
22.07.2022
Как работать с wso2CEP3.0.0 и activemq 5.8.0
Я использую wso2cep 3.0.0 и activemq5.8.0. Согласно документам CEP, я хочу публиковать события с использованием CEP. Для этого я запустил activemq с двумя определениями QUEUES с именем jmsProxy для входящего сообщения и JmsProxy для исходящего...
280 просмотров
schedule
19.05.2023
Развертывание в режиме распределенного кэша Siddhi
Согласно документам ( https://docs.wso2.org/display/CEP310/Clustered+Deployment ), вы можете запускать Siddhi в распределенном режиме.
Насколько я понимаю, все узлы будут совместно использовать определения потоков и работать в общем контексте...
516 просмотров
schedule
03.09.2022
Запрос Siddhi для вычисления нового значения с использованием значения текущего события и значения последнего события
Всякий раз, когда приходит событие, должен быть запрос для вычисления нового значения с использованием значения текущего события и значения последнего события и вставки его в новый поток. Например:
event [1] : speed = 0 timestamp =...
294 просмотров
schedule
11.08.2022
что такое данные корреляции метаданных и данные полезной нагрузки в wso2 cep
что такое данные корреляции метаданных и данные полезной нагрузки в wso2 cep
Я понял, что это 3 разных типа данных в потоке, но какой из них имеет преимущества перед другим, это не ясно из какой-либо документации. Или как мы можем использовать его...
605 просмотров
schedule
12.07.2022
Может ли wso2 siddhi CEP принимать поток пользовательских объектов? Можно ли указать правило для доступа к атрибутам объекта?
Я хочу передать объекты грузовика моему wso2 siddhi cep и оценить правило, чтобы поднимать тревогу каждый раз, когда truck.temperatureReading становится ниже 45 . Осуществимо ли это?
define stream truckStream (truck Truck)
from truckStream...
161 просмотров
schedule
10.09.2022
Пользовательская функция WSO2 CEP не работает как агрегатная функция
Пользовательская функция WSO2 CEP не работает как агрегатная функция, вместо этого она работает с каждой строкой данных.
Допустим, у нас есть значение1 и значение2 во входном потоке.
хост:A, значение1:1, значение2:10
хост:A, значение1:2,...
152 просмотров
schedule
14.02.2023
Как мне разделить сиддхиманагер в зависимости от контекста?
У меня есть несколько входящих потоков, и я использую wso2 для оценки этого потока с помощью правил. Некоторые из этих потоков можно объединить вместе, как если бы они были из одной организации. Как я могу разделить свой контекст сиддхи на основе...
83 просмотров
schedule
06.07.2022
Как реализовать непрерывное временное окно в CEP?
Скажем, у меня есть поток событий, и я хочу иметь возможность подсчитать их количество во временном окне. Я хотел бы получать уведомление всякий раз, когда событие входит во временное окно и изменяет счет, и то же самое, когда событие выходит из...
652 просмотров
schedule
29.07.2023
WSO2 CEP — вставка в несколько потоков
Как в SiddhiQL можно вставлять в несколько потоков с одинаковым условием?
Когда у меня есть два коррелированных события (event1 и event2) и я хочу вставить event1 в streamA; вставить событие2 в потокB; вставить abstractEvent в streamC.
Должен...
444 просмотров
schedule
01.06.2024
Расширенная таблица событий Siddhi для PostgreSQL
Мне нужно использовать таблицу событий с подключением к базе данных PostgreSQL по плану выполнения.
Я попытался расширить таблицу событий RDBMS расширения Siddhi (из ветки siddhi-master), и, выполняя тесты jUnit, я могу успешно взаимодействовать с...
242 просмотров
schedule
13.04.2023
WSO2 CEP + Обработка нулевых значений
В настоящее время CEP WSO2 запускается с использованием некоторых HTTP-запросов. Но иногда инициированный запрос имеет нулевые значения. В то время как обрабатывать эти нулевые значения с помощью CEP.
451 просмотров
schedule
22.12.2022
Siddhi CEP 3.x вопросы для новичков
Я новичок в Сиддхи, и у меня есть несколько вопросов:
Является ли SiddhiManager потокобезопасным? Является ли хорошей практикой один общий экземпляр на каждую JVM?
Как определить поток и добавить запрос во время выполнения? Похоже, у него...
382 просмотров
schedule
31.10.2022
Siddhi CEP - события, которые не были объединены в скользящее окно
У меня есть два потока, streamA и streamB . Каждый из streamA имеет идентификатор, и соответствующее событие в streamB будет иметь такой же идентификатор.
Я хочу узнать от streamA , какие идентификаторы не пришли streamB после...
161 просмотров
schedule
12.05.2023
Служба REST wso2 DAS или CEP
Могу ли я вызвать службу REST, которая использует параметр другого входного потока типа HTTP из siddhi?
Например:
У меня есть входной поток sensorStream:
@Import('org.wso2.event.sensor.stream:1.0.0')
define stream sensorStream...
96 просмотров
schedule
16.03.2023
WSO2CEP: определение потока/таблицы с идентификатором не было определено в плане выполнения
Я использую таблицу в памяти в плане выполнения, но компилятор спрашивает о ее определении. Запрос
@Import('MAINInStream:1.0.0')
define stream MAINInStream (ts string, uid string, id_orig_h string, id_orig_p int, id_resp_h string, id_resp_p int,...
107 просмотров
schedule
13.02.2023
WSO2 CEP — единая таблица событий для нескольких планов выполнения
Последние пару дней я изучал WSO2 CEP.
Я рассматриваю сценарий, в котором одна таблица поиска может использоваться в нескольких планах выполнения. Насколько я знаю, единственным способом хранения всех данных является таблица событий.
Мои...
133 просмотров
schedule
26.07.2022
как я могу использовать данные кэша wso2 siddhiQL?
Мой вопрос такой: я определяю доступ источника данных к данным в реальном времени в секунду (имеет), я буду использовать этот пакет данных в час для среднего расчета, а затем получить эту группу данных за час средней накопительной суммы , наконец,...
106 просмотров
schedule
09.10.2023
