Публикации по теме 'siddhi'
Легкая аналитика в реальном времени с помощью Spring Boot + WSO2 Siddhi
А вы ищете способ создать легкий механизм аналитики в реальном времени? В этой статье объясняется, как именно это сделать, объединив быструю, встраиваемую библиотеку аналитики в реальном времени (WSO2 Siddhi) с чрезвычайно популярная платформа микросервисов Spring Boot. В качестве бонуса я покажу вам, как это сделать за 5 минут с помощью генерации кода !. После прочтения этой статьи вы сможете сгенерировать полноценный проект загрузки Java Spring с документированным REST API,..
Вопросы по теме 'siddhi'
Siddhi CEP 4.x: несколько результатов для каждой группы при использовании временного пакетного окна
Использование сиддхи 4.1.0
Есть ли возможность применить time.windowBatch к предстоящим событиям? Я понял, что временное окно работает на основе уже поступивших событий.
Скажите, например,
Я получаю несколько результатов при использовании...
285 просмотров
schedule
29.10.2021
Как я могу выбрать значение из последовательного значения события с помощью сиддхи
например, это данные:
1,1470732420000,0
2,1470732421000,0
3,1470732422000,0
4,1470732423000,86
5,1470732424000,87
6,1470732425000,88
7,1470732426000,84
8,1470732427000,0
9,1470732428000,0
10,1470732429000,0
11,1470732430000,89
12,1470732431000,89...
203 просмотров
schedule
06.11.2021
wso2cep: ERROR - 'distance' не является ни расширением функции, ни расширением агрегированного атрибута в плане выполнения ExecutionPlan
Я использую версию WSO2 CEP 4.2.0, и я пишу план выполнения для проверки, когда координаты от разных датчиков не различаются более чем на 4 метра, с помощью запроса Siddhi. Но появляется ошибка: «расстояние» не является ни расширением функции, ни...
360 просмотров
schedule
05.09.2021
Разница между алгоритмами сопоставления с образцом, используемыми в CEP и Rule Engine, такими как слюни, сиддхи?
Алгоритмы сопоставления с образцом являются основными в механизме правил или механизме обработки сложного потока событий. Как я изучал, drools механизм правил использует rete алгоритм сопоставления с образцом. Что делает механизмы обработки...
613 просмотров
schedule
13.09.2021
siddhi gpl выполнение функции расстояния географического расширения выдает ошибку типа данных
Я пытаюсь создать приложение сиддхи, в котором он добавляет вывод, когда человек находится рядом с определенными предустановленными местоположениями. Эти местоположения хранятся в базе данных. На данный момент информация отправлена почтальоном....
103 просмотров
schedule
28.11.2021
ошибка с - ›не для сиддхи?
Я добавил следующий тестовый пример в AbsentWithEveryPatternTestCase.java, но тест не удался, и я думаю, что он должен быть успешным. Итак, есть ли ошибка с шаблоном "-> не для ..."?
@Test
public void testQuery7() throws InterruptedException {...
79 просмотров
schedule
02.12.2021
Как передать параметры функции прогнозирования тензорного потока в сиддхи?
Какие параметры передаются функции прогнозирования? Есть ли какая-либо документация по использованию плагина siddhi tensorflow?
Хотя в качестве части образца есть модель pbtxt, она сама по себе очень расплывчата и не содержит сведений о том, что...
177 просмотров
schedule
30.10.2021
Как обновить версию siddhi jars в рабочем контейнере w.r.t wso2sp?
Я пытаюсь заменить банки внутри рабочего контейнера wso2 4.4.0 на последнюю версию, а не на версию по умолчанию
Я пытался:
замените банку внутри контейнера
измените банку перед созданием базового образа, а также измените пакет в файле...
45 просмотров
schedule
14.10.2021
нет жизнеспособной альтернативы при вводе: Siddhi Query
Я пытаюсь написать простой запрос сиддхи, просто импортировав настраиваемый отображаемый поток. Но как только я импортирую поток и проверяю запрос, возникает ошибка.
Однако мой полный запрос
@Import('bro.in.ssh.log:1.0.0')
define stream...
760 просмотров
schedule
13.01.2022
Сиддхи объединяют события с данными из БД
Я хочу понять «до» и «не надо» в сиддхи. Я видел коннекторы БД и возможности обогащения потоковых событий данными из БД (скажем, коннектор cassandra).
Пример :
@primaryKey('id')
@store(type = 'rdbms', datasource = 'WSO2_TEST_DB')
define table...
132 просмотров
schedule
02.03.2022
Не удается получить доступ к службе WSO2 Stream Processor Studio из контейнера Docker
Я реализовал образец образа Docker для профиля редактора WSO2 Stream Processor с помощью следующего файла Dockerfile:
FROM ubuntu:16.04
MAINTAINER WSO2 Docker Maintainers "[email protected]"
# set user configurations
ARG USER=wso2carbon
ARG...
399 просмотров
schedule
05.03.2022
Преобразование файла CSV в событие Сиддхи
Я хочу преобразовать CSV-файл в набор событий Siddhi с помощью WSO2 Stream Processor, чтобы использовать этот CSV-файл для обучения модели kmeansIncremental.
Я попытался создать этот файл csv, используя «файл» в качестве типа источника и «csv» в...
163 просмотров
schedule
26.04.2022
Преобразование строки в проблему с двойной или плавающей точкой в потоковом процессоре WSO2
У меня есть файл CSV, который я хочу загрузить в потоковый процессор WS02 для имитации событий. У меня есть столбец с названием «Результат». Это строковый столбец в файле CSV.
В потоковом процессоре WSO2 я попытался преобразовать входящую строку...
346 просмотров
schedule
01.05.2022
Написание прибывших и отправленных запросов с помощью сиддхи с использованием таймаутов
Я хочу заменить Эспера на Сиддхи в своем приложении. Оператор esper прямо сейчас представляет собой шаблон типа тайм-аута, в котором мне нужно сообщать, когда приходят и уходят события с уникальным именем и типом (только строковые значения, которые я...
443 просмотров
schedule
27.05.2022
Сиддхи: игнорировать повторяющиеся события при активном шаблоне
У меня есть шаблон непредвиденных событий , чтобы определить, возникает ли определенное условие, а затем предупредить меня, если это условие не изменится в течение установленного времени. Приведенный ниже запрос можно описать как «Если для...
56 просмотров
schedule
17.06.2022
Консолидированный вывод в таблице с потоковым процессором Siddhi WSO2
У меня есть следующий запрос в Siddhi (потоковый процессор WSO2), где я пытаюсь получить окончательную сумму по округам, когда я отправляю поток из 10 событий (4 события для ABC, 6 событий для CDE). Но с помощью приведенного ниже запроса я получаю...
148 просмотров
schedule
03.07.2022
WSO2 CEP: можем ли мы использовать условные операторы if-else в планах выполнения?
Можем ли мы иметь условные операторы, как показано ниже, в плане выполнения wso2 cep.
from stream1
select distinct attr1
insert into newStream1;
from stream2
select distinct attr2
insert into newStream2;
if
count(attr1) == count(attr2)
then...
767 просмотров
schedule
11.07.2022
Как я могу интегрировать kafka с wso2 siddhi
У меня проблема с интеграцией kafka в wso2 siddhi. Я могу создать адаптер ввода kafka, но я не могу «настроить свойства входного сообщения адаптера событий kafka», как указано в документации.
Как указано в документации, я не смог найти приток в...
635 просмотров
schedule
09.08.2022
Понимание концепции моментального снимка сиддхи
У меня есть запрос и план выполнения, я хочу сделать его снимок, чтобы восстановить его на стороне получателя и начать выполнение снова.
Какой формат должен быть отправлен получателю?
Как восстановить на стороне получателя?
Ниже приведен...
276 просмотров
schedule
27.08.2022
Сиддхи, логическое И с внутри, неожиданно выполняет обратный вызов
Используя Siddhi CEP 3.1.2 в качестве автономной библиотеки, я пытаюсь выяснить, как правильно запускать обработчик обратного вызова при ряде условий.
Два события соединены логическим И
a AND b
С учетом вышеизложенного я обнаружил,...
115 просмотров
schedule
15.09.2022
