Pion CEP Platform - Reactor Plugins
Collection Reactors gather events from a variety of data sources such as page tags, server logs, and network packets, and deliver them to other Reactors for further processing or storage.
- Log File Input: (complete)
Plugin Filename: LogInputReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: uses a codec to automatically extract entries from your servers' system or daemon log files, and converts them into structured events - Packet Sniffer: (complete)
Plugin Filename: SnifferReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Passively sniffs network packets, reassembles TCP and decrypts SSL/TLS. Protocol plugins allow you to generate events from any type of network traffic. Initially, an HTTP Protocol is included to sniff website traffic (clickstream).
Processing Reactors filter, clean, sessionize, aggregate, and correlate events. Data can be processed from a single stream, or multiple streams of different types.
- Event Filter: (complete)
Plugin Filename: FilterReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: uses configurable rules to detect new events, sequences or patterns. Delivers events to the reactors it is connected to only when these occur. - Event Transformation: (complete)
Plugin Filename: TransformReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: creates new events which are derived from the events that it receives. This can be used: to create entirely new types of complex events (for example, to signify that a pattern has been detected), or to derive new attributes which are based on attributes in existing events (i.e. assign a new attribute to "Internet Explorer" if an existing attribute contains "MSIE"). - Clickstream Sessionizing: (complete)
Plugin Filename: ClickstreamReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Sessionizes a stream of HTTP request events (or clickstream hits) by grouping them into page views and sessionizes. Appends additional session attributes to the request events and produces two new types of events, one each for page views and sessions. Can also receive other types of events (such as order transactions) and correlate them to existing sessions. Note that Pion can accept JSON/HTTP requests directly from page tags embedded within website pages, or via AJAX requests sent from live web applications. Pion's FeedService converts these requests into events which can be delivered to a Clickstream Sessionizing reactor. These events can thus be used to track specific actions (including independent actions, sequences or complex patterns) within a website or web application. - Event Aggregation: (complete)
Plugin Filename: AggregationReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Aggregates information by counting the number of events received during an interval of time which have matching values for certain attributes. Produces new events representing the aggregated information. This will also store historical information into external database tables and provide reporting interfaces. - Script: (added in 1.1 release)
Plugin Filename: ScriptReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: executes a shell script to process each event it receives.
Storage Reactors save events to different types of data stores, including Pion’s embedded relational database.
- Log File Output: (complete)
Plugin Filename: LogOutputReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: uses a codec to store events into log files residing on the servers' local hard drive. Log files can be rotated based on size and time restrictions. - Database Output: (complete)
Plugin Filename: DatabaseOutputReactor
License: GPL Affero license
Publisher: Atomic Labs, Inc.
Purpose: stores events into either embedded or external transactional databases using Pion's Database plugins. - Google Analytics Reactor: (complete)
Plugin Filename: GoogleAnalyticsReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Replicates website page tags by delivering real-time clickstream events to Google Analytics using their HTTP interface. - Omniture Reactor: (added in 1.1)
Plugin Filename: OmnitureAnalyticsReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Replicates website page tags by delivering real-time clickstream events to Omniture using their HTTP Genesis API. - HTTP Output Reactor: (in progress for 1.2 release)
Plugin Filename: HTTPOutputReactor
License: Commercial license (closed source)
Publisher: Atomic Labs, Inc.
Purpose: Reliably delivers a stream of events over one or more HTTP connections. Includes automated failover functionality that stores events locally to a disk-based FIFO queue if the remote server is unavailable or consuming events too slowly. If the server is unavailable, it can either periodically attempt to re-establish the connection (and recover from the disk queue), or send the events to an alternative Pion server. It also allows you to evenly distribute work across a cluster of servers by performing hashing on the event data.
Custom Reactors
- Additional reactors can easily be built to accommodate whatever your needs may be. Please contact Atomic Labs for more information on our available professional services.
