Описание тега complex-event-processing
Комплексная обработка событий (CEP) состоит из обработки множества событий, происходящих на всех уровнях организации, определения наиболее значимых событий в облаке событий, анализа их воздействия и выполнения последующих действий в режиме реального времени.
1
ответ
Как выполнить сложную обработку событий, используя Esper с потоками, поступающими из данных CSV?
Я непрерывно отправляю строки CSV в темы Kafka, используя производителя Kafka, и генерирую поток строк CSV следующим образом температура =23,3, давление =1015, влажность =63,4, скорость ветра =7,4..... Теперь я хочу выполнить сложную обработку событ…
24 июл '18 в 13:45
1
ответ
Создание событий с вложенными свойствами с помощью INSERT INTO в Esper
Я определил тип события на основе XML PositionUpdate в Esper с вложенными свойствами, как показано ниже. <xs:schema xmlns:xs="http://www.w3.org/2001/XMLSchema" xmlns="PositionUpdate.xsd" targetNamespace="PositionUpdate.xsd" elementFormDefault="qu…
26 авг '14 в 08:40
1
ответ
Как сохранить отчетливость до тех пор, пока на EPL ESPER не будет выполнено определенное условие
У меня есть два типа событий (A и B). Я хотел бы написать шаблон, который обнаруживает каждое событие B, которое идет после события A с тем же идентификатором: every A -> B (A.id = B.id), Тем не менее, это должны быть разные идентификаторы. Други…
15 дек '16 в 06:59
1
ответ
Esper - удалить старые события из среды исполнения
У меня есть вопрос по поводу CEP-Engine Esper: Как я могу удалить старые события из среды выполнения, чтобы освободить память? Спасибо. Изменить: Извините, я имел в виду EPRuntime, а не время выполнения JVM
19 сен '15 в 20:27
1
ответ
Регулярное выражение IPv6 для извлечения в обработке событий
Мне нужно извлечь IP-адрес из сообщения журнала, чтобы определить причину проблемы. Я использую эту сложную обработку событий от dataanalytics360.com Текущая система имеет регулярное выражение для извлечения адреса IPv4, который ^.* (([0-9]{1,3})\.(…
11 июл '14 в 18:47
1
ответ
Стандартный язык или теория моделей для системы обработки сложных событий
Мы разрабатываем библиотеку для комплексной обработки событий. Существует ли какой-либо стандартный или общепринятый язык с четкой семантикой, на котором мы могли бы основываться? После некоторых исследований кажется, что все доступные опции зависят…
09 янв '14 в 09:17
1
ответ
Написать запрос и пользовательскую функцию в Esper
Я пытаюсь создать заявление EPL, которое покажет, возможен ли заказ или нет. Есть два события, EventA(обработано) и EventB(не обработано). создать схему EventA (тип string, процент Completed integer);создать схему EventB(тип string); Оператор должен…
11 авг '16 в 07:12
1
ответ
Могу ли я печатать отдельные элементы DataSteam<T> в Apache Flink без использования встроенной функции print()
Я пытаюсь напечатать значения предупреждений, которые были обнаружены в Flink // Генерируем температурные предупреждения для каждого соответствующего шаблона предупреждения DataStream<TemperatureEvent> warnings = tempPatternStream.select( (Map…
11 авг '17 в 03:12
2
ответа
Эспер - обнаружить отсутствие определенного события
Можно ли обнаружить отсутствие определенного типа события в заданном временном окне, не используя другие типы событий в Esper? Спасибо;)
03 авг '15 в 20:39
1
ответ
Самый эффективный способ записи более 1000 записей в таблицу базы данных
У нас есть продукт, который требует записи более 1000 записей в таблицу базы данных после утверждения сотрудником нашей компании. Традиционным способом записи этого количества записей может быть циклическая или массовая вставка MySQL непосредственно…
23 май '17 в 12:25
1
ответ
Начиная с Esper + сокеты
Я новичок с Эспером, и я хотел бы получить помощь. Мне уже удалось использовать Esper с файлами CSV, но теперь мне нужно использовать объекты Java в качестве событий, отправляемых через сокет, и я не могу найти в Интернете простые примеры, которые м…
01 окт '12 в 16:20
1
ответ
Сиддхи Джар не появляется в консоли углерода
В WSO2 CEP у меня есть пользовательская функция, которая выполняет некоторые вычисления; У меня есть запрос, как следующий String cseEventStream = "define stream eventStream (attribute string,attributeValue object);"; String query = "from eventStrea…
01 май '17 в 00:09
1
ответ
Обрабатывать сложные события
У меня есть поток отдельных событий, поступающих в мою систему, и мне нужно применять правила, основанные на содержании каждого события. Также я хочу применить сложную обработку событий к этим событиям потока. Ограничения 1. Эти правила предоставляю…
10 окт '13 в 21:36
1
ответ
Шаблон EPL, чтобы соответствовать последним A и всем B с фильтром
Я пытаюсь найти шаблон EPL, который будет соответствовать последнему A, за которым следует любой & all B(prop1=A.prop1). Используя ту же последовательность, как определено в документации Esper... A1 B1 C1 B2 A2 D1 A3 B3 E1 A4 F1 B4 Я ищу шаблон, кот…
13 апр '17 в 09:31
1
ответ
Esper фильтрует события по шаблону
Я пытаюсь выбрать некоторые события из потока через функцию match_recognize и получить сообщение об ошибке. Я не могу понять, почему мой шаблон не работает, или я что-то пропустил в своем заявлении. Может быть, кто-то может помочь мне с моим заявлен…
26 мар '15 в 13:12
1
ответ
Esper: Использование меток времени начала / окончания с POJO или типами событий, определенных во время выполнения
Я пытаюсь использовать методы алгебры временных интервалов непосредственно для типов событий, что, согласно документам, должно быть возможным. Сначала я попытался определить некоторые типы событий, используя create schema синтаксис, как это: create …
17 апр '12 в 16:08
1
ответ
Инструменты Azure Stream Analytics для Visual Studio: ошибка при выполнении агрегированных запросов - "Ссылка на объект не установлена для экземпляра объекта"
Мы следовали документации, использованной инструментами Azure Stream Analytics для Visual Studio, и сделали Visual Studio способной создавать проект Azure Stream Analytics. Мы создали задание Azure Stream Analytics(ASA) с локальными входными данными…
15 ноя '17 в 17:01
3
ответа
Обработка сложных событий
Недавно я изучал системы, основанные на событиях, и узнал о сложной обработке событий с использованием таких сред, как Apache Storm. Я понимаю, что CEP идеально подходит, когда вы имеете дело с большими потоками данных, и вы хотели бы обнаруживать о…
04 сен '14 в 00:56
1
ответ
Сравнение реактивного программирования и обработки сложных событий
Я читал о реактивном программировании и могу понять модель программирования и то, как мы можем использовать такие шаблоны, как CQRS, для создания микросервисов и приложений. Чем это отличается от устаревшего подхода к комплексной обработке событий, …
27 окт '16 в 16:02
5
ответов
Обработка сложных событий Python
Существуют ли какие-либо альтернативы Python, аналогичные Esper (Java и.NET), которые занимаются обработкой сложных событий (CEP)?
14 сен '10 в 07:54