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.
Complex Event Processor
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.
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
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 DemoMoney 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 DemoRisk 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 DemoStock Market Surveillance
Uses sophisticated monitoring for identifying complex trading patterns, detecting stock market manipulation in real time, and generating appropriate alerts.
Request a DemoThe 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 DemoAd 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 DemoProximity 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 DemoControlling 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 DemoNetwork 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 DemoThe 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 DemoSocial 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 DemoIn 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 DemoFeatures
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
- Getting Started
- Installation Guide
- Documentation
-
Quick Start Guide (Screencasts)
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.
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.
Resources
Demos
On-Demand Webinars
Articles
- Solving the DEBS 2016 Grand Challenge using WSO2 CEP
- WSO2 CEP In Action: an analysis of use in real world applications of different domains
- Geo Spatial Data Analysis Using WSO2 Complex Event Processor
- Natural Language Processing with WSO2 CEP
- Real-time Intruder Detection with R, PMML, and WSO2 CEP
- Implementing a WSO2 CEP Extension to Run Machine Learning Models Written in PMML Format
- Integrating Apache UIMA with WSO2 CEP
- Achieve Scalability and Performance With Partitioning In WSO2 CEP
- Distributed Scaling of WSO2 Complex Event Processor
- Get Near Real-Time API Traffic Notifications with WSO2 Complex Event Processor
- Geo Fencing for Internet of Things with WSO2 CEP
