Обработка потока событий - Event stream processing
- Слиться с Потоковая обработка
Обработка потока событий, или же ESP, представляет собой набор технологий, призванных помочь в строительстве событийные информационные системы. Технологии ESP включают в себя визуализацию событий, базы данных событий, промежуточное ПО, управляемое событиями, и языки обработки событий, или сложная обработка событий (CEP). На практике термины ESP и CEP часто используются как синонимы. ESP решает задачу обработки потоков данных событий с целью определения значимого шаблона в этих потоках, используя такие методы, как обнаружение взаимосвязей между несколькими событиями, корреляция событий, иерархии событий и другие аспекты, такие как причинность, членство и время. .
ESP позволяет использовать множество различных приложений, таких как алгоритмическая торговля в финансовых услугах, определение радиочастоты (RFID) приложения для обработки событий, Обнаружение мошенничества, мониторинг процесса, и геолокационные сервисы в телекоммуникациях.
Примеры
В качестве иллюстрации следующие фрагменты кода демонстрируют обнаружение шаблонов в потоках событий. Первый - это пример обработки потока данных с использованием непрерывного SQL query (запрос, который выполняет непрерывную обработку поступающих данных на основе временных меток и продолжительности окна). Этот фрагмент кода иллюстрирует СОЕДИНЕНИЕ двух потоков данных: одного для заявок на акции и одного для результирующих сделок с акциями. Запрос выводит поток всех Ордеров, соответствующих Сделке в течение одной секунды после размещения Ордера. Выходной поток сортируется по метке времени, в данном случае метке времени из потока заказов.
ВЫБРАТЬ Поток данных Заказы.Отметка времени, Заказы.номер заказа, Заказы.бегущая строка, Заказы.количество, Торговля.количествоИЗ ЗаказыПРИСОЕДИНИТЬСЯ Сделки НАД (КЛАССИФИЦИРОВАТЬ ИНТЕРВАЛ '1' ВТОРОЙ СЛЕДУЮЩИЙ)НА Заказы.номер заказа = Сделки.номер заказа;
Другой фрагмент кода-примера обнаруживает свадьбы среди потока внешних «событий», таких как звон церковных колоколов, появление мужчины в смокинге или утреннем костюме, женщины в развевающемся белом платье и летающий по воздуху рис. «Сложное» или «составное» событие - это то, что можно сделать из отдельных простых событий: свадьба.
КОГДА Человек.Пол РАВНЫЕ "человек" И Человек.Одежда РАВНЫЕ "смокинг"СЛЕДУЕТ-К Человек.Одежда РАВНЫЕ "платье" И (Церковь - Белл ИЛИ ЖЕ Рис - летающий)В 2 часыДЕЙСТВИЕ Свадьба
Смотрите также
- Обработка сложных событий (CEP) - Связанная технология для построения и управления информационными системами, управляемыми событиями.
- Система управления потоками данных (DSMS) - тип программной системы для управления потоками данных и запросов к ним.
- openPDC Полный набор приложений для обработки потоковых данных временных рядов в реальном времени.
- Вычисления в реальном времени - Системы ESP обычно представляют собой системы реального времени
- RFID - Радиочастотная идентификация или RFID рекомендует применение ESP для предотвращения переполнения данных
- SCADA - Диспетчерский контроль и сбор данных, аналогичные технологии, используемые в инженерных приложениях
- Apache Flink - Платформа потоковой обработки с открытым исходным кодом для распределенных масштабируемых потоковых приложений
- Потоковый процессор WSO2 - Открытый исходный код Запаренный SQL основанная на потоковой обработке структура для распределенных масштабируемых потоковых приложений
Рекомендации
- MIT / Brown / Brandeis Проект обработки потока "Аврора"
- Проект «ТРУБЫ» в Марбургском университете
- Сила событий Дэвид Лакхэм (ISBN 0-201-72789-7), из Стэнфордского университета, книга по CEP.
- Отделение пшеницы от плевел Статья о КЭП применительно к RFID появилась в RFID Journal
- Комплексная обработка событий и анализ в реальном времени - Источник нейтральной в отрасли информации о приложениях, исследованиях, сценариях использования, эталонных архитектурах и разработках в области обработки событий, управляемый профессором Дэвидом Лакхэмом.
- Одиссей - Фреймворк с открытым исходным кодом для механизмов обработки событий на основе Java