Из Википедии, бесплатной энциклопедии
  (Перенаправлено из обработки потока событий )
Перейти к навигации Перейти к поиску
Слияние с потоковой обработкой

Обработка потока событий , или ESP , - это набор технологий, предназначенных для помощи в построении информационных систем, управляемых событиями . Технологии ESP включают в себя визуализацию событий, базы данных событий, промежуточное программное обеспечение, управляемое событиями, и языки обработки событий или сложную обработку событий (CEP). На практике термины ESP и CEP часто используются как синонимы. ESP решает задачу обработки потоков данных событий с целью определения значимого шаблона в этих потоках, используя такие методы, как обнаружение взаимосвязей между несколькими событиями, корреляция событий, иерархии событий и другие аспекты, такие как причинность, членство и время. .

ESP поддерживает множество различных приложений, таких как алгоритмическая торговля финансовыми услугами, приложения для обработки событий радиочастотной идентификации (RFID), обнаружение мошенничества , мониторинг процессов и услуги на основе определения местоположения в телекоммуникациях.

Примеры [ править ]

В качестве иллюстрации следующие фрагменты кода демонстрируют обнаружение шаблонов в потоках событий. Первый - это пример обработки потока данных с использованием непрерывного SQL- запроса (запроса, который выполняет непрерывную обработку поступающих данных на основе временных меток и продолжительности окна). Этот фрагмент кода иллюстрирует СОЕДИНЕНИЕ двух потоков данных: одного для заявок на акции и одного для результирующих сделок с акциями. Запрос выводит поток всех Ордеров, соответствующих Сделке в течение одной секунды после размещения Ордера. Выходной поток сортируется по метке времени, в данном случае метке времени из потока заказов.

ВЫБЕРИТЕ  заказы DataStream  . TimeStamp , Заказы . orderId , Заказы . тикер , Заказы . сумма , Торговля . сумма ИЗ Ордеров ПРИСОЕДИНЯЙТЕСЬ к Сделкам ВЫШЕ ( ИНТЕРВАЛ ДИАПАЗОНА «1» ВТОРОЙ СЛЕДУЮЩИЙ ) ПО Ордерам . orderId = Сделки . orderId ;

Другой фрагмент кода-примера обнаруживает свадьбы среди потока внешних «событий», таких как звон церковных колоколов, появление мужчины в смокинге или утреннем костюме, женщины в развевающемся белом платье и летающий по воздуху рис. «Сложное» или «составное» событие - это то, что можно сделать из отдельных простых событий: свадьба.

КОГДА  Человек . Пол  РАВНО  «человек»  И  Person . Одежда  РАВНО  «смокинг» СЛЕДОВАЛИ - BY  Person . Одежда  РАВНО  «платье»  И  ( Church_Bell  ИЛИ  Rice_Flying ) В ТЕЧЕНИЕ  2  часа ACTION  свадьбы

См. Также [ править ]

  • Комплексная обработка событий (CEP) - родственная технология для построения и управления информационными системами, управляемыми событиями.
  • Система управления потоками данных (DSMS) - тип программной системы для управления потоками данных и запросов к ним.
  • openPDC Полный набор приложений для обработки потоковых данных временных рядов в реальном времени.
  • Вычисления в реальном времени - системы ESP обычно представляют собой системы реального времени.
  • RFID - радиочастотная идентификация, или RFID, рекомендует применение ESP для предотвращения переполнения данных.
  • SCADA - диспетчерский контроль и сбор данных, аналогичная технология, используемая в инженерных приложениях.
  • Apache Flink - платформа обработки потоков с открытым исходным кодом для распределенных масштабируемых приложений потоковой передачи данных.
  • WSO2 Stream Processor - фреймворк потоковой обработки на основе Steaming SQL с открытым исходным кодом для распределенных масштабируемых потоковых приложений.

Ссылки [ править ]