Описание тега cep

Описание тега Вопросы с тегом
Комплексная обработка событий (CEP) состоит из высокоскоростной обработки многих событий на всех уровнях организации.
1 ответ

Запрос с Сиддхи CEP, используя два раза окна

Я пытаюсь сделать простой запрос, но с двумя временными окнами; запрос будет выглядеть как попытка отправить сообщение пользователям, которые посещали веб-продукт более двух раз за последние четыре месяца, при условии, что вы уже отправили в прошлом…
23 апр '15 в 13:53
2 ответа

Как очистить окно CEP

Я хотел заблокировать одно и то же событие (которое имеет один и тот же заголовок), дважды входящее в поток inOrg. Поэтому я использовал "первое уникальное" окно. Но в какой-то момент это приведет к ошибке нехватки памяти. Я хочу очистить первое уни…
05 сен '16 в 05:05
1 ответ

Проблема библиотеки CEP в Apache flink (кластер)

У меня довольно простое приложение, хорошо работающее в Eclipse. При развертывании в кластере происходит очень быстрый сбой: java.lang.RuntimeException: не удалось найти основной метод (String[]) из класса org.ice.drmcl.Application: org/apache/flink…
19 авг '17 в 09:54
1 ответ

Как хранение старых событий влияет на производительность в esper?

Как хранение старых событий влияет на производительность в esper? Например, - Как влияет на производительность, если мы храним 10 старых событий и как изменится производительность, если мы храним 100 старых событий. Будут ли какие-либо изменения? Я …
02 авг '16 в 09:52
1 ответ

Получить объект в потоке из Сиддхи

У меня есть расширение Siddhi, которое возвращает следующую информацию, например: { "licenseKey": "WxyzChXjhJ-dgjfZfHnL9-bWd4e2vxjD-eIs5hDu0To-VOxL111BAj", "siteUrl": "http://www.URL.net/", "clientPublicId": "CLIENT1", "host": "www.urlclient.net" } …
26 июл '16 в 21:20
1 ответ

Как я могу объединить два потока, упорядоченных и сгруппированных по меткам времени?

У меня есть два потока объектов, каждый из которых имеет Timestamp значение. Оба потока расположены по порядку, поэтому, например, временные метки могут быть Ta = 1,3,6,6,7 в одном потоке и Тб = 1,2,5,5,6,8 в другом. Объекты в обоих потоках относятс…
16 мар '12 в 18:06
1 ответ

Как Wso2CEP выбирает сообщения в JMS

Я использую wso2cep 3.0.0 и activemq5.8.0 Согласно документам CEP, я хочу публиковать события, используя CEP. Для этого я начал activemq с 2, определив QUEUES с именем jmsProxy для входящего сообщения и JmsProxy для входящего сообщения. Я добавил тр…
04 мар '14 в 06:15
1 ответ

Комплексная обработка событий с гибким и динамическим шаблоном событий

Это общий вопрос по обработке сложных событий. Можно ли сделать полноценный общий компонент CEP с пользовательским интерфейсом, где пользователи могут определять свои собственные правила и система работает. Поместить это в другое Есть ли смысл делат…
10 апр '17 в 06:00
2 ответа

CEP Engine vs Expert System

Каковы основные различия между модулем обработки сложных событий и механизмом экспертной системы? Когда я должен использовать тот или иной?
21 ноя '11 в 18:03
1 ответ

Комплексная обработка событий - потоковая обработка

Я пытаюсь понять, как Esper сотрудничает с Storm. Я смотрю на исходный код Esper, потому что хочу узнать, где Esper хранит данные (таблицы, массивы и т. Д.). Например, когда esper получает поток кортежей и тип события объявляется, как эти данные хра…
24 ноя '16 в 21:05
1 ответ

wso2 CEP 4.0.0-SNAPSHOT и кассандра. Это работает?

Я скачал wso2 cep 4.0.0-SNAPSHOT от jenkins около 2 недель назад. Когда я настраиваю выходной издатель cassandra из cep, я связываю его с потоком событий. Когда я тестирую поток событий, вызывается выходной издатель кассандры, и у меня есть исключен…
17 сен '15 в 15:26
1 ответ

Что входит в ответ на вопрос "Написание собственного брокера о WSO2 CEP"

У меня такой же вопрос для написания собственного брокера о WSO2 CEP на статью ссылки, г-н Моханадаршан ответил Mohanadarshan Но я не могу понять ссылку пакета в ответе на ссылку статьи. И у меня нет времени, используя это переполнение стека. Так чт…
08 сен '13 в 14:36
1 ответ

Сиддхи Как отследить, что происходит внутри ExecutionPlanRuntime

Есть ли способ отслеживать / регистрировать внутреннее выполнение плана выполнения Сиддхи? Сейчас я говорю о ванильных сиддхи, а не о WSO2 CEP. Я не нашел способа как его включить. Как вы отлаживаете свои правила? Благодарю.
22 сен '16 в 14:27
1 ответ

Как выполнить сложную обработку событий, используя Esper с потоками, поступающими из данных CSV?

Я непрерывно отправляю строки CSV в темы Kafka, используя производителя Kafka, и генерирую поток строк CSV следующим образом температура =23,3, давление =1015, влажность =63,4, скорость ветра =7,4..... Теперь я хочу выполнить сложную обработку событ…
24 июл '18 в 13:45
1 ответ

Функции времени Esper не работают

Заявления EPL, касающиеся родного времени, не работают в Esper. Я использую версию 5.3.0. Я не могу получить что-то со временем, чтобы выступить правильно. timer:within(1 sec) У меня были проблемы с настройкой таймера. я имею and операторы, добавлен…
06 авг '18 в 23:06
1 ответ

Клиентские запросы Esper хорошо подходят для нескольких клиентов

Насколько я понял, Esper построен с использованием запросов, чтобы различать, что важно, а не во входящем событии. Я подумываю об использовании Esper, но не уверен, хорошо ли он подходит для моего сценария. Мой сценарий: Мне нужно отследить нескольк…
14 дек '12 в 11:34
1 ответ

Ошибка Cepheus Broker не передает обновления Cepheus CEP

Я использую Cepheus GE для своего случая использования, и я включил его в мультитенантном режиме и загрузил свой config.json файл, но когда я начинаю отправлять обновления брокеру Cepheus, чтобы переслать их в CEP, брокер Cepheus просто получает обн…
02 сен '17 в 10:43
1 ответ

Как включить несколько операторов в конечную точку Apache Camel - Esper?

У меня есть список утверждений Esper, которые я хотел бы выполнить в потоке Apache Camel. Как я могу убедиться, что все утверждения оцениваются для всех сообщений? Нужно ли иметь отдельный маршрут для каждого оператора Esper (например, из: esper: //…
19 авг '15 в 11:16
1 ответ

Слюни Правило для обработки 2 разных фактов, вставленных в определенное время

Мне нужно разобраться с ситуацией, когда меня уведомляют, когда в мою рабочую память поступают 2 разных факта в течение 30 секунд друг от друга. Затем я хочу, чтобы система удалила факты из рабочей памяти после их обработки. Например, я хочу получит…
16 фев '14 в 16:35
1 ответ

Как получить один выходной поток для нескольких операторов в Esper?

Я новичок в Esper и пытаюсь получить результаты нескольких EPStatements для запуска через один и тот же UpdateListener. Например: EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(); EPStatement avgStatement = epService.getEP…
07 мар '15 в 20:08