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

редактировать
Объединить с Обработка потока

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

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

Примеры

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

ВЫБРАТЬ DataStream Orders.TimeStamp, Orders.orderId, Orders.ticker, Orders.amount, Trade.amount ИЗ Ордеров ПРИСОЕДИНЯЙТЕСЬ к сделкам ВЫШЕ (ДИАПАЗОННЫЙ ИНТЕРВАЛ «1» ВТОРОЙ СЛЕДУЮЩИЙ) НА Orders.orderId = Trades.orderId;

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

КОГДА Person.Gender РАВНО "мужчина" И Person.Clothes EQUALS "tuxedo" FOLLOWED-BY Person.Clothes EQUALS "gown" И (Church_Bell OR Rice_Flying) В ТЕЧЕНИЕ 2 часов ДЕЙСТВИЯ Свадьба
См. Также
  • Сложное событие processing (CEP) - соответствующая технология для построения и управления информационными системами, управляемыми событиями.
  • Система управления потоками данных (DSMS) - тип программной системы для управления потоками данных и запросов к ним
  • openPDC Полный набор приложений для обработки потоковых данных временных рядов в реальном времени.
  • Вычисления в реальном времени - Системы ESP обычно представляют собой системы реального времени
  • RFID - Радиочастотные идентификация, или RFID, рекомендует применение ESP для предотвращения переполнения данных
  • SCADA - диспетчерский контроль и сбор данных, аналогичная технология, используемая в инженерных приложениях
  • Apache Flink - потоковая обработка с открытым исходным кодом фреймворк для распределенных масштабируемых приложений потоковой передачи данных
  • WSO2 Stream Processor - открытый исходный код Steaming SQL ba Платформа обработки потока sed для распределенных масштабируемых приложений потоковой передачи данных
Ссылки
Последняя правка сделана 2021-05-19 08:36:09
Содержание доступно по лицензии CC BY-SA 3.0 (если не указано иное).
Обратная связь: support@alphapedia.ru
Соглашение
О проекте