Click here to close now.


Microsoft Cloud Authors: Jordan Sanders, Carmen Gonzalez, Pat Romanski, Keith Mayer, Jayaram Krishnaswamy

Related Topics: Microservices Expo, Java IoT, Industrial IoT, Microsoft Cloud, IoT User Interface, Apache

Microservices Expo: Article

Intelligent Complex Event Processing with Artificial Neural Network

Solve highly complex problems in real or near real time

In the current world, data is continuously being generated across various layers of organizations and environment due to changes in the system states or due to the occurrence of new events. These changes in the state of the existing system can happen due to the arrival of a new order request, customer service calls for complaints or feedback, changes in the company stock prices, text or multimedia messages, emails, social media posts, traffic reports, weather reports or any other kind of data. Simply producing reports using these data on a pre-defined schedule is not enough. Decision makers need real-time alerts and intelligent insight of all that is happening within and around the organization so that they may take meaningful reactive and proactive action before it is too late based on the new information being continuously generated.

A powerful technique called Complex Event Processing (CEP) is used for analyzing events coming from multiple sources over a specific period of time by detecting complex patterns between events and by making correlations. Apart from CEP, Artificial Neural Network (ANN) is also used to model complex relationships between input events data. Both the approaches have their own pros and cons. In this article, we tried to describe a use case in the health care domain with the solution architecture using both CEP and ANN, combining the best capabilities of both the approaches. We have shown how one can use both the techniques together to solve highly complex problems in real or near real time.

The following two sections gives brief introduction about CEP and ANN respectively with their key benefits. In section 4, we have explained the approach which combines both the CEP and the ANN efficiently to provide better solution of complex problems. Section 5 and 6 explains the Health Care: Patient Monitoring System use case with the problem description and proposed solution approach using CEP and ANN, followed by the section with summary and conclusion.

Complex Event Processing
Complex event processing is one of the key Operational Intelligence technology used to process one or more stream of data and information (also known as events) and deriving a meaningful conclusion using them. It allows one to set the request for an analysis or some query and then have it continuously executed and evaluated over time against one or many streams of events in a highly efficient manner. CEP is all about processing events that combines data from many sources to infer events or patterns that suggest more complicated circumstances [1].  For example, CEP can be used as Fraud Detection system, to detect suspicious credit card usage by monitoring credit card activity in real time and relating the current transactions with the historical data about a particular customer. The historical data which can be used by CEP Fraud Detection system can be an average transaction amount, minimum and maximum values of the previous transactions, transaction frequencies, locality etc. On detecting fraudulent activity, CEP system can send an alert via an SMS or email to the customer or the credit card service provider to take quick reaction.

The primary goal of CEP is to (1) detect meaningful events or pattern of events which signifies either threats or opportunities from the series of events being received continuously and (2) send alerts for the same to responsible entity to respond as quickly as possible. The following diagram (as figure-1) describes high level view of the CEP system.

Figure 1: High-level view of the CEP system

As shown in Figure 1, the core of the complex event processing system is made up of set of input adapters, set of output adapters and various event processing modules such as event filtering modules, in-memory caching, aggregation over different windows (time-window, sliding window, tumbling window etc.), database lookups module, database writes module, correlation, joins, event pattern matching, state machines, dynamic queries etc. More the number of I/O adapters supported by the CEP, more flexible and adaptable it is and will be able to cover wide range of use cases as compared to the CEP tool having support for limited set of I/O adapters.

Key Benefits of CEP
The following are some of the key benefits the CEP provides to the business.

  • Automatically identifies rare but important relationships between seemingly unrelated events or stream of events and accelerate timely responses to both the threats and opportunities.
  • Using sophisticated analysis and event pattern matching techniques, the CEP improves resource allocation and timely problem resolution by prioritize situations that require the most urgent attention in real or near real time based on arrival of events.
  • CEP helps organization to reduce operating costs by monitoring end-to-end performance of the system and provide timely alerts to rapidly identify potential SLA violations.
  • CEP helps organization to fine tune their business processes by correlating SLA performance with industry metrics e.g. Six Sigma and various Quality metrics, to enhance overall productivity.

Artificial Neural Network
An Artificial Neural Network (ANN) is a computational model which resembles with the way human brain is made up of in structure and the way it works. Similar to human brain which is made up of billions of neurons interconnected by synapses, the ANN can be form as a network of computational nodes connected with each other through links. The ANN needs to be trained repeatedly with specific set of training data before it can be used in production environment. Due to its adaptive nature, the internal structure of the ANN can easily be changed based on external or internal information that flows through the network during the learning phase [2]. The links are assigned weights during training process, which regulate the flow of data from one node to another. ANNs are used to model complex relationships between inputs and outputs data. ANN can efficiently find various patterns in input data or to predict future values of the system parameters. Due to its flexible construct, ANN can be very helpful in modeling complex systems which are very difficult otherwise by using traditional modeling techniques. Artificial neural networks are being applied in diverse of domains and fields. They are extensively used for doing image processing and recognition, speech recognition, credit card fraud detection, for prediction of protein structure in biotechnology and in the field of genetic science.

Artificial neural network consists of two types of interfaces with the external world, the input and the output. Since the ANN is made up of nodes or neurons and the links between them, a subset of total nodes in the ANN act as input nodes, which take data from the external world, a subset of nodes act as output node, which produces result and zero or more hidden nodes act as intermediary nodes, with having only connections with input or output nodes or other hidden nodes.  Hence, the ANN is made up of nodes in input layer, nodes in output layer and zero or more internal layers.

Figure 2: High-level view of artificial neural network

The high level view of ANN is shown in figure-2. The diagram shows a typical neural network with total 12 nodes, three nodes in the input layer, seven nodes in the hidden layer and two nodes in the output layer. Before the neural network can be used in actual production environment, it is needed to be trained for particular environment. The process of training of ANN is called learning of neural network, which is generally done in one of the following three ways:  (a) supervised learning; (b) unsupervised learning and (c) reinforcement learning. The more details about the ANN learning can be found in [2].

Key Benefits of ANN
Since ANNs can infer a function from inputs, they particularly are used in the applications where the complexity of the input data or system modeling makes the design of such a function impractical using traditional approaches. Following are some of the key benefits ANN provides.

  • It is very easy to apply ANN to problem domains where the relationships are quite dynamic or non-linear among the input and output.
  • Since ANN is capable of capturing many kind of relationships and complex patterns among data, ANN allows user to easily model the system which otherwise is very difficult or impossible to represent through traditional modeling approaches.
  • The training information is not stored in any single element but is distributed in the entire network structure. This makes ANN fault tolerant and it reduces the impact of erroneous input on the result.

CEP and ANN Together
Having seen the key properties and benefits of using both, CEP and ANN, this section describes what if one apply both together for specific set of problems to make the modeling of the system and solution easy and efficient. The CEP is best in accepting data or events from multiple channels and apply various event processing operations on it, such as event filtering, event pattern matching, aggregation etc. Apart from that user can configure alerts based on various thresholds on various system parameters. But the CEP tools lakes the ability to predict future events or determine the values of the system parameters for future events, which can be efficiently done by the ANN. So if we combine best of CEP and best of ANN for a particular problem, the resulting solution could be very effective and efficient. In the following sections, we have described how the CEP and the ANN can be used together to solve a particular problem of patient monitoring system in the domain of Health care and medicines.

Patient Monitoring System
The patient monitoring system monitors and keeps track of various body parameters of the patient and provides the data for analysis to monitoring system. Various body parameters could be blood pressure, the percentage of oxygen in the blood, glucose level in the blood, heart beat rate, change in body temperature etc. Data provided by the patient monitoring system helps to make diagnostic decisions easy and more reliable. The quality of patient treatment and care giving can greatly be improved with the use of patient monitoring systems, since it allows generating alerts in case of sudden changes in the patient body parameters which could be dangerous to the patient's health or could be life threatening some time [3].

A Use Case
Goals of the patient monitoring system are to (1) continuously keeps track of the patient's body parameters and store the data for present or future references, (2) identify life-threatening changes in patient's body and raises timely alarms for the same, and (3) to determine whether patient's health is in normal condition or it is improving or worsening based on the continuously arriving input data from various medical monitors. Since no two human bodies react in a same way against given situation or medication, it is very difficult to derived common rule set which can be applied to all human bodies. Similarly, one person's body also reacts differently in different medical and environmental situations. For example, a particular heart beat rate can be normal in some situation, while the same can be very abnormal in the other situation. So to judge the proper health condition, a trained professional is required, i.e. a specialist doctor, who studies all the observations and determine the correct state of patient's health. If the patient monitoring system is equipped with some intelligent agent who will use patient's medical history and current body parameters observations, then quality of patient care delivery can greatly be improved. We combine CEP and ANN together to propose system architecture which tries to act as an intelligent agent of the patient monitoring system, which is described in the following section.

System Architecture of the intelligent patient monitoring system using CEP and ANN
The following diagram, in Figure 3, shows the architecture of the intelligent patient monitoring system using CEP and ANN. There are total five key components; (1) Medical monitors, (2) CEP, (3) Patient's medical history and diagnosis data store, (4) ANN and (5) ANN output to action message converter.

(1) Medical Monitors
Medical monitors are medical devices used for monitoring patient's body parameters. It can consist of one or more body parameter sensors, processing components, display devices as well as communication links for displaying, recording or transmitting data or results elsewhere through a monitoring network. In the proposed architecture, the data generated by medical monitors are fed into the CEP system. [3]

Figure 3: Architecture of the intelligent patient monitoring system using CEP and ANN

The CEP section of the proposed architecture is one of the key components of the system. It receives all the monitored data and applies various event processing techniques, such as filtering, aggregation etc. over input event streams and provides the data for further processing to ANN module. Various input adapters available in CEP make it possible to collect data from different types of sensors or monitors and process them collectively. In CEP module, various event processing rule are written specific to the patient.

(3) Patient's medical history and diagnosis data store
This is the data store where patient's medical history and diagnosis data is stored. It could be traditional RDBMS storage system. The data stored in this storage are used for ANN training purpose. The new data is continuously added into the same data storage and will be used next time when ANN will be trained again with patient's latest medical and diagnosis data.

(4) ANN
The ANN model for the patient is computational neural network specific to the patient and trained using patient's all medical and diagnosis data. This trained ANN model is used for real-time diagnosis and care delivery. The decision is taken based on the input data coming from the CEP output adapters. The patient specific ANN model is trained at regular interval may be daily or on need bases. These regular updates which include latest knowledge about measured body parameters, diagnosis and medication information of the patient, helps ANN model to make accurate predictions. It is also possible to make ANN take biased decision by giving more weight to either historical data or the latest data during training. All these make ANN the most critical component of the system.

(5) ANN output to action message converter
The output generated by the ANN is generally real numbers and they are needed to be mapped to the meaningful information so that appropriate action can be taken. This is done by the ANN output to action message converter. The module not only map ANN output to real world information but it can also sends action data or alerts to devices or human being through email, SMS, alarm system etc. The threshold for various alerts can be configured so it can adapt to the changes happening to the health and body.

Together all these components make a very flexible, intelligent and efficient patient monitoring system. The proposed architecture shows how one can use CEP and ANN together more effectively to model the complex problem and provide efficient solution alternative over the traditional approaches.

Complex event processing and artificial neural network are the two widely used solution techniques for the problems that are very difficult to model using traditional approaches. In this article, we have described both the approaches in brief with their key capabilities. We have also described a use case for intelligent patient monitoring system with the solution architecture using both CEP and ANN and combining the best capabilities of both the approaches. We have shown how one can use both the techniques together to solve highly complex problems in real or near real time.


  1. Complex event processing,
  2. Artificial neural network,
  3. Patient Monitoring Systems - Part 1,

More Stories By Kamalkumar Mistry

Kamalkumar Mistry is a Technology Analyst at Infosys Limited, Pune, India. At Infosys, he is part of a research group called Infosys Labs (

Comments (0)

Share your thoughts on this story.

Add your comment
You must be signed in to add a comment. Sign-in | Register

In accordance with our Comment Policy, we encourage comments that are on topic, relevant and to-the-point. We will remove comments that include profanity, personal attacks, racial slurs, threats of violence, or other inappropriate material that violates our Terms and Conditions, and will block users who make repeated violations. We ask all readers to expect diversity of opinion and to treat one another with dignity and respect.

@ThingsExpo Stories
Continuous processes around the development and deployment of applications are both impacted by -- and a benefit to -- the Internet of Things trend. To help better understand the relationship between DevOps and a plethora of new end-devices and data please welcome Gary Gruver, consultant, author and a former IT executive who has led many large-scale IT transformation projects, and John Jeremiah, Technology Evangelist at Hewlett Packard Enterprise (HPE), on Twitter at @j_jeremiah. The discussion is moderated by me, Dana Gardner, Principal Analyst at Interarbor Solutions.
Too often with compelling new technologies market participants become overly enamored with that attractiveness of the technology and neglect underlying business drivers. This tendency, what some call the “newest shiny object syndrome” is understandable given that virtually all of us are heavily engaged in technology. But it is also mistaken. Without concrete business cases driving its deployment, IoT, like many other technologies before it, will fade into obscurity.
With all the incredible momentum behind the Internet of Things (IoT) industry, it is easy to forget that not a single CEO wakes up and wonders if “my IoT is broken.” What they wonder is if they are making the right decisions to do all they can to increase revenue, decrease costs, and improve customer experience – effectively the same challenges they have always had in growing their business. The exciting thing about the IoT industry is now these decisions can be better, faster, and smarter. Now all corporate assets – people, objects, and spaces – can share information about themselves and thei...
The Internet of Things is clearly many things: data collection and analytics, wearables, Smart Grids and Smart Cities, the Industrial Internet, and more. Cool platforms like Arduino, Raspberry Pi, Intel's Galileo and Edison, and a diverse world of sensors are making the IoT a great toy box for developers in all these areas. In this Power Panel at @ThingsExpo, moderated by Conference Chair Roger Strukhoff, panelists discussed what things are the most important, which will have the most profound effect on the world, and what should we expect to see over the next couple of years.
Growth hacking is common for startups to make unheard-of progress in building their business. Career Hacks can help Geek Girls and those who support them (yes, that's you too, Dad!) to excel in this typically male-dominated world. Get ready to learn the facts: Is there a bias against women in the tech / developer communities? Why are women 50% of the workforce, but hold only 24% of the STEM or IT positions? Some beginnings of what to do about it! In her Day 2 Keynote at 17th Cloud Expo, Sandy Carter, IBM General Manager Cloud Ecosystem and Developers, and a Social Business Evangelist, wil...
PubNub has announced the release of BLOCKS, a set of customizable microservices that give developers a simple way to add code and deploy features for realtime apps.PubNub BLOCKS executes business logic directly on the data streaming through PubNub’s network without splitting it off to an intermediary server controlled by the customer. This revolutionary approach streamlines app development, reduces endpoint-to-endpoint latency, and allows apps to better leverage the enormous scalability of PubNub’s Data Stream Network.
Discussions of cloud computing have evolved in recent years from a focus on specific types of cloud, to a world of hybrid cloud, and to a world dominated by the APIs that make today's multi-cloud environments and hybrid clouds possible. In this Power Panel at 17th Cloud Expo, moderated by Conference Chair Roger Strukhoff, panelists addressed the importance of customers being able to use the specific technologies they need, through environments and ecosystems that expose their APIs to make true change and transformation possible.
Microservices are a very exciting architectural approach that many organizations are looking to as a way to accelerate innovation. Microservices promise to allow teams to move away from monolithic "ball of mud" systems, but the reality is that, in the vast majority of organizations, different projects and technologies will continue to be developed at different speeds. How to handle the dependencies between these disparate systems with different iteration cycles? Consider the "canoncial problem" in this scenario: microservice A (releases daily) depends on a couple of additions to backend B (re...
I recently attended and was a speaker at the 4th International Internet of @ThingsExpo at the Santa Clara Convention Center. I also had the opportunity to attend this event last year and I wrote a blog from that show talking about how the “Enterprise Impact of IoT” was a key theme of last year’s show. I was curious to see if the same theme would still resonate 365 days later and what, if any, changes I would see in the content presented.
Apps and devices shouldn't stop working when there's limited or no network connectivity. Learn how to bring data stored in a cloud database to the edge of the network (and back again) whenever an Internet connection is available. In his session at 17th Cloud Expo, Ben Perlmutter, a Sales Engineer with IBM Cloudant, demonstrated techniques for replicating cloud databases with devices in order to build offline-first mobile or Internet of Things (IoT) apps that can provide a better, faster user experience, both offline and online. The focus of this talk was on IBM Cloudant, Apache CouchDB, and ...
Container technology is shaping the future of DevOps and it’s also changing the way organizations think about application development. With the rise of mobile applications in the enterprise, businesses are abandoning year-long development cycles and embracing technologies that enable rapid development and continuous deployment of apps. In his session at DevOps Summit, Kurt Collins, Developer Evangelist at, examined how Docker has evolved into a highly effective tool for application delivery by allowing increasingly popular Mobile Backend-as-a-Service (mBaaS) platforms to quickly crea...
With major technology companies and startups seriously embracing IoT strategies, now is the perfect time to attend @ThingsExpo 2016 in New York and Silicon Valley. Learn what is going on, contribute to the discussions, and ensure that your enterprise is as "IoT-Ready" as it can be! Internet of @ThingsExpo, taking place Nov 3-5, 2015, at the Santa Clara Convention Center in Santa Clara, CA, is co-located with 17th Cloud Expo and will feature technical sessions from a rock star conference faculty and the leading industry players in the world. The Internet of Things (IoT) is the most profound cha...
Internet of @ThingsExpo, taking place June 7-9, 2016 at Javits Center, New York City and Nov 1-3, 2016, at the Santa Clara Convention Center in Santa Clara, CA, is co-located with the 18th International @CloudExpo and will feature technical sessions from a rock star conference faculty and the leading industry players in the world and ThingsExpo New York Call for Papers is now open.
The cloud. Like a comic book superhero, there seems to be no problem it can’t fix or cost it can’t slash. Yet making the transition is not always easy and production environments are still largely on premise. Taking some practical and sensible steps to reduce risk can also help provide a basis for a successful cloud transition. A plethora of surveys from the likes of IDG and Gartner show that more than 70 percent of enterprises have deployed at least one or more cloud application or workload. Yet a closer inspection at the data reveals less than half of these cloud projects involve production...
Cloud computing delivers on-demand resources that provide businesses with flexibility and cost-savings. The challenge in moving workloads to the cloud has been the cost and complexity of ensuring the initial and ongoing security and regulatory (PCI, HIPAA, FFIEC) compliance across private and public clouds. Manual security compliance is slow, prone to human error, and represents over 50% of the cost of managing cloud applications. Determining how to automate cloud security compliance is critical to maintaining positive ROI. Raxak Protect is an automated security compliance SaaS platform and ma...
In his keynote at @ThingsExpo, Chris Matthieu, Director of IoT Engineering at Citrix and co-founder and CTO of Octoblu, focused on building an IoT platform and company. He provided a behind-the-scenes look at Octoblu’s platform, business, and pivots along the way (including the Citrix acquisition of Octoblu).
There are over 120 breakout sessions in all, with Keynotes, General Sessions, and Power Panels adding to three days of incredibly rich presentations and content. Join @ThingsExpo conference chair Roger Strukhoff (@IoT2040), June 7-9, 2016 in New York City, for three days of intense 'Internet of Things' discussion and focus, including Big Data's indespensable role in IoT, Smart Grids and Industrial Internet of Things, Wearables and Consumer IoT, as well as (new) IoT's use in Vertical Markets.
Today air travel is a minefield of delays, hassles and customer disappointment. Airlines struggle to revitalize the experience. GE and M2Mi will demonstrate practical examples of how IoT solutions are helping airlines bring back personalization, reduce trip time and improve reliability. In their session at @ThingsExpo, Shyam Varan Nath, Principal Architect with GE, and Dr. Sarah Cooper, M2Mi’s VP Business Development and Engineering, explored the IoT cloud-based platform technologies driving this change including privacy controls, data transparency and integration of real time context with p...
The Internet of Things (IoT) is growing rapidly by extending current technologies, products and networks. By 2020, Cisco estimates there will be 50 billion connected devices. Gartner has forecast revenues of over $300 billion, just to IoT suppliers. Now is the time to figure out how you’ll make money – not just create innovative products. With hundreds of new products and companies jumping into the IoT fray every month, there’s no shortage of innovation. Despite this, McKinsey/VisionMobile data shows "less than 10 percent of IoT developers are making enough to support a reasonably sized team....
We all know that data growth is exploding and storage budgets are shrinking. Instead of showing you charts on about how much data there is, in his General Session at 17th Cloud Expo, Scott Cleland, Senior Director of Product Marketing at HGST, showed how to capture all of your data in one place. After you have your data under control, you can then analyze it in one place, saving time and resources.