This documentation is for WSO2 Complex Event Processor 4.0.0. View documentation for the latest release.
||
Skip to end of metadata
Go to start of metadata

Introduction

This sample demonstrates how to set up an execution plan with a quartz scheduler based cron window for generating periodic alerts on build failures. 

The execution plan used in this sample is as follows:

from buildStatisticsStream[isBuildFailed == true]#window.cron("0 0 1 * * ?")
select project, productTeam, lastCommitter, count(timeStamp) as totalBuildFailures
group by project
insert into buildFailureStream;

The first query,

  • Receives events through the buildStatisticsStream
  • Adds events that satisfy the condition isBuildFailed == true to a cron window. The cron window is configured to output at 1 am every day using the cron notation.
  • Selects the attributes project, productTeam, lastCommitter, count(timeStamp) as totalBuildFailures
  • The group by clause causes the count() to be calculated per project.
  • Outputs events to the buildFailureStream

Prerequisites

See Prerequisites in CEP Samples Setup page.

Building the sample

Start the WSO2 CEP server with the sample configuration numbered 0115. For instructions, see Starting sample CEP configurations. This sample configuration does the following:

  • Points the default Axis2 repo to <CEP_HOME>/sample/artifacts/0115 (by default, the Axis2 repo is <CEP_HOME>/repository/deployment/server).

Executing the sample

  1. Open another terminal, go to <CEP_HOME>/samples/producers/http and run the following command:

    ant -Durl=http://localhost:9763/endpoints/buildStatisticsEventReceiver -Dsn=0115

    It builds the http client and publishes the events at  <CEP_HOME>/samples/artifacts/0115/buildStatisticsEvents.txt to the buildStatisticsEventReceiver http endpoint.

  2. You can see the events getting received by CEP by the logs in its console. 

The above query will output the processed events at "1 am" as defined in the execurion plan. You can edit the query in "BuildFailureStatisticsPlan.siddhiql" file which is located in <CEP_HOME>/samples/artifacts/0115/executionplans to reschedule as per requirement.
Below is an example of a scheduler related query which outputs processed events on 5th minute each hour. For more information see Inbuilt Windows.

from buildStatisticsStream[isBuildFailed == true]#window.cron("0 5 * * * ?")
select project, productTeam, lastCommitter, count(timeStamp) as totalBuildFailures
group by project
insert into buildFailureStream;
  • No labels