1
Complex Event Processor

WSO2 Complex Event Processor (WSO2 CEP) was created as a mechanism to offer a standalone real-time analytics solution and we now have this capability within WSO2 Data Analytics Server (WSO2 DAS). Try it now!

WSO2 Complex Event Processor (WSO2 CEP) helps identify the most meaningful events and patterns from multiple data sources, analyze their impacts, and act on them in real time. 100% open source, it allows you a set up a more agile connected business, responding to urgent business situations with both speed and precision.

From enabling healthcare providers develop real-time clinical decision support systems, to monitoring transactions and tracking vehicles in smart cities, WSO2 CEP is highly performant, massively scalable, and offers significant savings in both cost and time.

WSO2 CEP is available on-premise, on top of WSO2 Private PaaS or on any public cloud such as Amazon AWS. It is an integral part of the WSO2 Analytics Platform, where it provides the real time analytics pipeline.

  • Better Transport for a better London:
    We Won TfL’s Data in Motion Hackathon

    Read More

  • WSO2 cited as a Strong Performer in Forrester WaveTM:
    Big Data Streaming Analytics, Q1 2016

    Read More

  • WSO2 Named a 2016 Cool Vendor in Internet of Things Analytics by Gartner

    Read More

Complex Event Processor

Version 4.2.0

Capabilities

WSO2 CEP facilitates real time event detection, correlation and notification of alerts, combined with rich visualization tools to help build monitoring dashboards.

It utilizes a high-performance streaming processing engine which is the outcome of extensive research at WSO2. Thanks to its architecture, memory optimizations and new approaches to storing event data, WSO2 CEP is one of the fastest open source solutions available today, able to find events patterns in real-time milliseconds.

Overview
Overview
Overview
Overview

At the heart of WSO2 CEP is Siddhi. Configured using a rich, compact, easy to learn SQL-like language, WSO2 CEP is especially suited for complex queries involving time windows, as well as patterns and sequences detection. CEP queries can be changed dynamically at runtime using templates. The core streaming engine is low-latency, extremely small in size and can be deployed for edge analytics - that is, the execution of event processing flows on a device or IoT gateway. This, coupled with its ability to handle extremely large volumes of event streams, makes WSO2 CEP particularly well-suited to handle IoT scenarios.

WSO2 CEP can be deployed in standalone or distributed modes. In distributed mode, it leverages Apache Storm architecture for nearly linear scalability. Pre-built solutions such as fraud detection and geo fencing leverage the power of WSO2 CEP and provide domain specific implementations on top of the core engine.

Performance

  • A single WSO2 CEP node can handle 100K+ events per second over network on commodity hardware (e.g. 4 cores, 4 GB RAM)
  • Capable of processing 6 million events per second with events generated from same JVM
  • Finalist in DEBS Grand Challenge 2014 and 2015 (based on building single-node and distributed solutions running queries across 4 billion events collected from smart homes equipped with a total of 2000 sensors)

Solutions

Banking and Finance

Modern markets and banking environments present large amounts of information - sometimes so much that the human eye cannot pick out the threads from among thousands of patterns in the data.

Using our powerful real-time, batch and predictive capabilities, we’ve built open source solutions specialized for these needs.

Fraud Detection

Converts domain knowledge into generic rules, models unknown types of fraud, and presents interactive data visualizations to investigate fraudulent activities.

Request a Demo

Money Laundering Detection

Uses machine learning to detect known activity patterns, identifies unknown behavior patterns, correlates geographically disparate laundering events and detects suspicious activity sequences.

Request a Demo

Risk Management

Listens to market prices as well as real time changes to portfolios and computes Value at Risk in real time, using historical simulation, parametric method and Monte Carlo simulation.

Request a Demo

Stock Market Surveillance

Uses sophisticated monitoring for identifying complex trading patterns, detecting stock market manipulation in real time, and generating appropriate alerts.

Request a Demo

eCommerce and Marketing

The United Nations Conference on Trade and Development estimates the global ecommerce market to be worth $22 trillion. The world has long since evolved beyond simple shopping carts - customers, too, now expect advanced systems that not only cater to their needs, but can predict them.

At WSO2, we’ve built open source solutions that harness the power of analytics to help you delivering this level of customer experiences for a state-of-the-art shopping experience.

Recommendations Engine

Considers multiple attributes based on a shopper’s buying history, current buying trends, inventory status, active promotions and others to make intelligent product recommendations.

Request a Demo

Ad Optimization

Uses streams of incoming data to help identify targeted audiences, user preferences and to select more appropriate and personalized advertising on the fly.

Request a Demo

Proximity marketing

Harnesses iBeacons and mobile infrastructure to process and analyse customer behavior, explore this data for business improvement and enhance customer experiences with tailored, real-time, reactive marketing methods.

Request a Demo

Fleet Management

Controlling fleets of transport vehicles is an imposing task, made simpler and more accurate by technology.

By analyzing data emitted from sensors attached to vehicles in a fleet, WSO2 provides a comprehensive set of features for any organization to monitor their fleet in real time, stay ahead in the maintenance schedules, detect and predict risks in order to take proactive actions to mitigate risks.

With technologies like RFID, it's now possible to have even closer control of the management of goods that's being transported - as well as the transportation media. With the right hardware and WSO2, goods can be tracked and monitored from the point of origin all the way to your consumers.

Request a Demo

Network Monitoring

Network security and maintenance is a serious task: on average, it costs an enterprise more than half a million USD to recover from a breach.

By harnessing the power of machine learning, WSO2’s open-source solution can act as a high-performance network monitor acting in real time, detecting network intrusions and botnet attacks.

Not only does this add faster-than-human detection and responses to your network security; machine learning also goes beyond traditional algorithmic ways of detection, which may be unable to respond to new and evolving threats.

Request a Demo

Smart Energy Analytics

The ever-increasing influx of real-time data engineering, production, and equipment sources, the energy industry faces unique opportunities for analyzing the use of technologies, processes, and shifts in trends.

WSO2 provides an open source solution for continuous analysis and real-time monitoring to analyze demand, predict and optimize energy flow, monitor production facilities and assets, and various other activities, visualizing real-time data using built in dashboards.

A comprehensive set of features cater to a wide variety of analytics demands, including those of Smart Grids, Smart Homes and Oil and Gas Industries.

Request a Demo

Social Media Analysis

Social media is one of the most powerful communication tools available today, but any worthwhile analysis requires processing large data sets of thousands and perhaps millions of tweets, status updates and the like.

WSO2 CEP provides some powerful tools for social media analysis, from keyword and topic analysis to visually graphing community interactions, sentiment and bias on social media. It also allows you to perform location-based analysis.

WSO2 allows you to sift through terabytes of social media data in both stored and real-time scenarios, allowing you to identify customers, interact and drive your product with exceptional clarity.

Request a Demo

QoS Enablement

In production, a system must not just be well-designed; it must be constantly monitored, and issues that tend to affect the operation of the system must be identified and responded to.

WSO2 CEP is capable of monitoring incoming data streams to identify instances of low throughput, event drops, errors, latency issues, jitter and out-of-order delivery, and enables both visualization of these events and rapid responses to them.

Given the right data, CEP is capable of dynamically prioritizing requests, rate limiting and throttling, blacklisting, detecting anomalies and eliminating outliers in real time. It’s a powerful way of ensuring automated that your systems maintain quality of service no matter what.

Request a Demo

Features

Process data in motion, and analyze in real time

  • Works as a streaming pipeline, processing one event at a time, allowing to detect conditions and react to them in real time.
  • Handle massive amounts of streamed events (100,000 events per second and above) due to low-latency engine.
  • Detection of out-of-order events and ability to smooth event streams (remove noise) by using Kalman filtering.
  • Supports data partitioning for optimized execution of queries in a distributed deployment.

Rich configuration language

  • Uses a rich and compact SQL-like query language covering the most complex event processing flows configuration.
  • Supports event streams filtering by conditions, as well as event streams transformation.
  • Supports the aggregation and correlation of one or multiple event streams.
  • Supports temporal patterns detection, logical patterns detection, as well as events sequences.
  • Includes capability to enrich event streams with historical data stored in databases, files or external data source.
  • Supports parameterized templates for dynamic editing and deployment of queries by non-technical users.

Scalability and High availability

  • Supports standalone fault tolerant deployment, with or without event streams persistence.
  • Supports distributed deployment on top of Apache Storm architecture.
  • Includes specific streaming operators to drive parallel execution on Apache Storm.

Connect and integrate with anything

  • Event streams can be received and sent in XML , JSON, Text or Map format.
  • Supports standards transport receivers and publishers, including HTTP(s), JMS, files or SOAP, REST or Email, Apache Thrift or Web sockets.
  • Support for IoT-friendly transports such as MQTT or Apache Kafka.
  • Events can be published in data repositories such as RDBMS or Apache Cassandra.
  • Supports the addition of custom data connectors in Java.
  • Supports 100+ legacy and cloud applications when combined with the WSO2 ESB

Business Applications

  • Interactively create dashboards, including support for gadget generation from event stream definitions.
  • Configure pre-built queries via a web application, with no need to know about the underlying language.

Application Development

  • Try It capability to learn the configuration language by testing a query against a sample data set.
  • Visualize event processing flow and simulate event streams
  • Replay data sets from a file or a database
  • Embed into enterprise applications for event streams publishing

Operational Management

  • Ability to collect statistics data at several points of the event processing flow and visualize in embedded dashboards or via JMX.
  • Ability to record and replay events to troubleshoot production systems.
  • Ability to instrument, monitor and visualize operational metrics

Getting Started

Customer Success Stories

Pacific Controls is an innovative company delivering an IoT platform of platforms: Galaxy 2021. The platform allows to manage all kinds of devices within a building and take automated decisions such as moving an elevator or starting the air conditioning based on certain conditions. Within Galaxy2021, WSO2 CEP is used for monitoring alarms and specific conditions.

Watch video

The Cleveland Clinic, ranked among the top 3 hospitals in the US, uses a Clinical Intelligence Platform that combines big data storage, stream and batch processing to provide decision support to clinicians. Real-time analytics for the platform is provided by WSO2 CEP along with custom extensions to handle healthcare data.

Watch video

More Customer Success Stories

Resources

Demos

WSO2 CEP Realtime Analytics for Football
WSO2 CEP Geo Dashboard
WSO2 CEP Road traffic Map
WSO2 CEP Traffic prediction
WSO2 CEP TfL Demo

On-Demand Webinars

Data to Insight in a Flash: Introduction to Real-Time Analytics with WSO2 Complex Event Processor
Data to Insight in a Flash: Introduction to Real-Time Analytics with WSO2 Complex Event Processor
An Introduction to Large Scale Data Analysis with the WSO2 Analytics Platform
An Introduction to Large Scale Data Analysis with the WSO2 Analytics Platform
Catch Them in the Act: CEP for Real-time Ecommerce Influence
Catch Them in the Act: CEP for Real-time Ecommerce Influence

Articles

Presentations

Tracking A Soccer Game with Big Data
Tracking A Soccer Game with Big Data
Scalable Realtime Analytics with declarative SQL like Complex Event Processing Scripts
Scalable Real-time Analytics With Complex Event Processing Scripts
Scalable Event Processing with WSO2 CEP
Scalable Event Processing with WSO2 CEP

Videos

Decide and Do By Knowing With WSO2 CEP
Decide and Do By Knowing With WSO2 CEP
Report Security Vulnerabilities
Products
Projects
Cloud
Solutions
Company
Support
Learn
SIGN UP FOR OUR NEWSLETTER

Follow us

LEARN ABOUT SECURITY AT WSO2 >

This website uses cookies so that we can provide you with the best user experience. Read our Cookie Policy to find out more.

If you wish to disable cookies you can do so from your browser.

I Understand
^