Описание тега siddhi
Siddhi CEP is a lightweight, easy-to-use Open Source Complex Event Processing Engine (CEP) under Apache Software License v2.0. Siddhi CEP processes events which are triggered by various event sources and notifies appropriate complex events according to the user-specified queries.
1
ответ
Запрос с Сиддхи CEP, используя два раза окна
Я пытаюсь сделать простой запрос, но с двумя временными окнами; запрос будет выглядеть как попытка отправить сообщение пользователям, которые посещали веб-продукт более двух раз за последние четыре месяца, при условии, что вы уже отправили в прошлом…
23 апр '15 в 13:53
1
ответ
wso2 cep Siddhiql объединяет данные из 2 потоков
Я хочу сделать статистику и статистика в процентах. У меня есть запрос, который сообщает мне количество событий, приходящих из одного потока, который содержит несколько значений ['R', 'B', 'A', 'C']. И я хочу посчитать, сколько Bs есть в stream1 в п…
03 фев '17 в 17:11
1
ответ
Получить объект в потоке из Сиддхи
У меня есть расширение Siddhi, которое возвращает следующую информацию, например: { "licenseKey": "WxyzChXjhJ-dgjfZfHnL9-bWd4e2vxjD-eIs5hDu0To-VOxL111BAj", "siteUrl": "http://www.URL.net/", "clientPublicId": "CLIENT1", "host": "www.urlclient.net" } …
26 июл '16 в 21:20
0
ответов
Mqtt сообщения не публикуются в Siddhi из C
Я пытаюсь опубликовать mqtt-сообщения на процессор Siddhi Stream. Я мог бы отправить сообщение из моей программы на C, а rc равен 0. Проблемы с подключением нет, но сообщение не опубликовано в Siddhi. Мой код C для публикации сообщений mqtt: #define…
07 авг '18 в 14:00
0
ответов
Siddhi http-sink игнорирует ошибку сертификата ssl
Читая из Siddhi-io-http, я не могу понять, как обойти ошибки сертификации ssl (то есть: истек или самоподписан). Есть параметр с именем ssl.verify.client, но нет информации о том, какие значения он принимает. Кто-нибудь знает как это сделать? Полное…
16 ноя '18 в 11:07
1
ответ
Сиддхи Как отследить, что происходит внутри ExecutionPlanRuntime
Есть ли способ отслеживать / регистрировать внутреннее выполнение плана выполнения Сиддхи? Сейчас я говорю о ванильных сиддхи, а не о WSO2 CEP. Я не нашел способа как его включить. Как вы отлаживаете свои правила? Благодарю.
22 сен '16 в 14:27
3
ответа
Расширение не существует для esbAnalytics: распаковать
Я пытаюсь распаковать входящие события с помощью приложения siddhi на потоковом процессоре WSO2. В более ранней версии (например, DAS) было расширение siddhi esbAnalytics: декомпрессия, но если я использую это расширение в SP, возникает ошибка "Расш…
08 фев '18 в 11:57
1
ответ
Соответствие отсутствию событий
У меня есть простой поток состояния объектов: define stream statusStream (id string, success bool); Я хочу запросить все объекты, которые "не удалось" (success=false) с 5 минут: все события statusStream (, false), где нет события (тот же идентификат…
11 янв '17 в 18:29
1
ответ
wso2: cep: siddhi: как сделать временные окна постоянными
В настоящее время мы тестируем siddhi wso2 cep. нам нужно иметь возможность перезапустить процесс сервера wso2 без потери данных, которые были накоплены в окне (например, временном окне). Есть ли способ сделать временные окна постоянными, чтобы серв…
03 дек '13 в 10:17
1
ответ
Выбрать значения по NULL в DAS Stream
У меня есть поток с несколькими атрибутами. Предположим, что имя потока - "MyStream", и оно импортируется в план выполнения как "my". Имена атрибутов: "А" и "В". Атрибут "B" может иметь значения NULL. Я хочу выбрать "A" и "B", где "B" - NULL. Я пыта…
16 окт '17 в 12:55
1
ответ
Как работать с wso2CEP3.0.0 и activemq 5.8.0
Я использую wso2cep 3.0.0 и activemq5.8.0 Согласно документам CEP, я хочу публиковать события с использованием CEP. Для этого я начал activemq с 2, определив QUEUES с именем jmsProxy для входящего сообщения и JmsProxy для входящего сообщения. Я доба…
18 фев '14 в 07:29
1
ответ
При потоковом событии Join в WSO2 CEP каждое выходное событие выдавливает два раза
Я использую WSO2 CEP, встроенный в WSO2 DAS Для следующего плана выполнения @Import('RelatedStream:1.0.0') define stream rs (ID string, product string, uc1 string, state string, brand string, model string, type string, tweet string, rtID string); @I…
25 май '16 в 03:44
2
ответа
CEP, как обнаружить и сообщить о дубликатах в потоке?
Есть ли способ обнаружить и сообщить о дубликатах в потоке? пример: поток данных для входа пользователя, содержащий кортежи с именем пользователя и IP-адресом. Цель состоит в том, чтобы обнаружить вход одного и того же пользователя с разных IP-адрес…
13 июл '13 в 06:41
1
ответ
Присоединиться к 3 событиям в Сиддхи
Я хочу присоединиться к условно выбранным 3 событиям в Сиддхи. Я делаю это, определяя два запроса в пределах определения сегмента. Вот первое определение запроса: from inStream[severity == 1] as a1 join inStream[name == 'name1'] as a2 on a1.time == …
28 июн '13 в 08:46
0
ответов
Как удалить определенный раздел по ключу явно в siddhiQL
Сиддхи могут разделять как входящие события и запросы, так и обрабатывать их параллельно в изоляции с разделением. увидеть следующий синтаксис: partition with ( deviceID of TempStream ) begin from TempStream#window.length(10) select roomNo, deviceID…
30 ноя '17 в 07:40
1
ответ
Ошибка 403 - Запрещено при входе в консоль управления Siddhi CEP
Я смотрел Сиддхи из терминала, используя ./bin/wso2server.sh и получил следующую ошибку при попытке войти в систему с помощью admin а также admin [2018-01-21 20:56:25,707] INFO {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - Mgt Console URL…
22 янв '18 в 01:59
1
ответ
Использовать временную метку внешнего окна для отладки Siddhi Stream Query
Я планирую использовать исторические трассировки событий (хранящиеся в JSON с моей собственной меткой времени события, записанной для каждого события) для отладки запросов потока сиддхи, которые я только что создал. Мой поток начинается с: из MyInpu…
13 июн '18 в 22:03
2
ответа
Баночка для выдвижных сиддхи
Я хочу расширить сиддхи, мой код Java: package org.wso2.siddhi.extension.fraude; import org.wso2.siddhi.core.config.ExecutionPlanContext; import org.wso2.siddhi.core.executor.ExpressionExecutor; import org.wso2.siddhi.core.executor.function.Function…
06 июн '16 в 04:23
1
ответ
Как определить временное окно сиддхи для полного текущего дня
Каков синтаксис написания выражения временного окна сиддхи только для текущего дня. Я хочу рассчитать количество групп событий по любому атрибуту события только для сегодняшней даты. Я планирую использовать #window.time(86400000), но предположим, чт…
12 мар '14 в 03:46
1
ответ
Как я могу использовать данные кеша wso2 siddhiQL?
У меня такой вопрос, я определяю доступ источника данных к данным в режиме реального времени в секунду (имеет), я буду рассчитывать на этот пакет данных в час для среднего вычисления, а затем иметь эту группу данных в час для средней накопленной сум…
18 дек '16 в 13:48