The first step in stream processing is to collect the data that needs to be analyzed. Collection of data is done through Siddhi source which can be defined via
@source() annotation on a steam.
To collect data to be processed a stream should have been defined in the Siddhi Application along with the
@source() annotation and deployed in WSO2 SP. Here a single SiddhiApp can contain multiple streams and each of those steams can also contain multiple
Example Input Source definition as below.
The source defines the following :
- Input source type: via
type = 'http'
- Source type configurations (This is optional. In this example http source type configurations are defined via
- Input message format: with
- Custom attribute mapping of the input message format (optional): with optional
@attributes( name='$.name', amount='$.quantity')sub-annotation of
A source can also be defined externally and referred to from several siddhi applications as shown below. Multiple sources can be defined in the
<SP HOME>/conf/<PROFILE>/deployment.yaml file. A
<PROFILE> can be a dashboard, editor, manager or worker. The following is a sample configuration of a source.
<SP HOME>/conf/<PROFILE>/deployment.yamlfile from a Siddhi application as shown in the example below.
For detailed instructions to configure a source, see Siddhi Guide - Source.
WSO2 SP supports following source types out of the box, to receive events via corresponding transports. Click on the required source type for instructions to configure a source to receive events via them.
WSO2 Siddhi allows events to be received in multiple formats. The following formats are currently supported. Once an event is received in a specific format, it is internally converted to a Siddhi event so that it can be processed by applying the WSO2 Siddhi logic. Click on the required format for detailed information on how a source can be configured to receive events in that format.