WikiDer > Обработка потока событий

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