This sample demonstrates how to set up an execution plan with a Siddhi query that monitors Twitter feeds of organizations using Siddhi partitions. It uses the following Siddhi query to check whether the word count of the Twitter feeds of each company within the last minute is greater than 10, and publishes the details of the companies with a high frequency of Twitter feeds as the output. This query has one incoming custom event stream of the word counts of various company names taken from Twitter pages. Custom events are events with custom mappings that does not adhere to the default event formats. For more information on event formats, see Event Formats.
Set up the prerequisites required for all samples.
Building the sample
Start the WSO2 CEP server with the sample configuration numbered 0112. For instructions, see Starting sample CEP configurations. This sample configuration creates the following.
Two streams with the IDs
An event receiver named
An event publisher named
HighFrequentTweetsLoggerto log the received messages
An execution plan named
Executing the sample
<CEP_HOME>/samples/cep/producers/wso2-eventdirectory, and execute the following Ant command using another tab in the CLI:
ant -DstreamId=twitterFeed:1.0.0 -Dsn=0112
The other optional parameters that can be used in the above command are defined in the
You view the CEP server receiving the output events in the logs of it in the CLI as shown below.