Toolbox

The below tables list the Stream Objects (Listener, Transformation, Action Agent, Context Provider & Function) available for use in XMPro.

Connector Tiers

Tier 1 Connectors – Social & Communication
Tier 2 Connectors – Database & Technology
Tier 3 Connectors – ERP & Advanced App
Tier 4 Connectors – Data Science & Vendor Built
Tier 5 Connectors – Free & Open Source

Listeners

Icon	Listener	Description	Tier
	Amazon Kinesis	The Amazon Kinesis Listener allows users to subscribe to an Amazon Kinesis Stream.	2
	Asset Administration Shell	This agent allows listening to changes in an AAS in real time.	2
	Azure Event Hub	This listener allows you to read events from Azure Event Hub.	2
	Azure IoT Hub	This listener allows you to read events from Azure IoT Hub.	2
	Azure Smart Contract	Listens for updates to an Azure Smart Contract.	2
	Azure SQL	Monitors and reads new records from a Azure SQL database.	5
	Azure Time Series	Allows the user to read time series data from Azure.	2
	Cisco Kinetic	This Listener allows integration to Cisco Kinetic over MQTT channel.	2
	Cisco ParStream	Allows the user to monitor and read new records from Cisco ParStream.	2
	ClearSCADA	This listener allows you to read tag values from ClearSCADA server.	2
	CSV	Allows the simulation of a stream using a CSV file.	5
	Email (POP3)	Allows the user to listen to Mail Server using POP3 protocol.	5
	Ethereum Smart Contract	Listens for an event fired by an Ethereum smart contract.	2
	Event Simulator	Use this Agent to simulate events.	5
	Excel File Reader	Reads Excel files and allows field extrapolation based on cell background colour.	2
	File	Monitors a directory for files.	5
	GE Predix – Time Series	Allows the user to read Time Series data from GE Predix using the REST APIs.	2
	HP Vertica IoT	A listener to monitor and read new records from a HP Vertica system.	3
	IBM Maximo	This listener allows you to monitor and read new records from IBM Maximo system.	3
	InfluxDB	This listener agent monitors and reads new records from the configured InfluxDB.	2
	MOVUS Alarms	This agent allows you to read latest alarms from MOVUS devices.	2
	MOVUS Device Samples	This agent allows you to read latest device samples.	2
	MQTT	A generic MQTT listener.	5
	MQTT Advanced	Receives data from a device or any source that uses the MQTT messaging protocol.	5
	MySQL	Allows user to monitor and read new records from MySQL database.	2
	ODBC	A listener to monitor and read new records from an ODBC data source.	2
	OPC DA Listener	This agent reads the latest OPC DA data available.	2
	OPC HDA Listener	This agent allows you to read trending data from OPC HDA server.	2
	OPC UA	Allows the user to read Tag data from OPC UA Server.	2
	Oracle	The stream object listens for new data from an Oracle Server.	2
	OSIsoft PI	Reads data from OSIsoft PI Systems using AFSDK.	2
	SQL Server	Monitors and reads new records from a database.	5
	Stream Log	This listener allows you to retrieve logs from the Stream Host.	5
	Wonderware	This listener allows you to monitor and read tag data from Wonderware Historian database.	2

Context Providers

Icon	Context Provider	Description	Tier
	ABB Ellipse – Assets	This context provider allows you to read data from an ABB Ellipse system.	3
	Asset Administration Shell	This agent provides contextual data from AAS.	2
	Azure Digital Twin	Fetches contextual data from Azure Digital Twins.	2
	Azure SQL	Provides context/static data using XMPro Connector for Azure SQL databases.	5
	CSV	This Context Provider allows you to read a CSV file and output the entire contents to the stream.	2
	D&B Company Profile	This Context Provider returns the company profile for a given Duns number.	2
	D&B Identity Search	This agents provides context using the D&B API.	2
	GE Predix – Assets	Provides context/static data using GET operations of REST APIs provided by GE Predix – Asset Service.	3
	HP Vertica IoT	This context provider allows you to read data from a HP Vertica system.	3
	IBM Maximo	This context provider allows you to read data from the IBM Maximo system to apply context.	3
	JSON File Reader	An agent to read a JSON formatted file, containing an Array of records, as Context.	5
	MOVUS Device Samples	This agent allows you to retrieve device samples from specified number of days.	2
	MOVUS Devices	This agent allows you to retrieve list of devices.	2
	MySQL	This agent allows you to retrieve context/static data from MySQL database.	2
	OData	This context provider allows you to read data from the OData system to apply context.	2
	OSIsoft PI	Provides context/static data using XMPro Connector for OSIsoft PI.	3
	REST API	The REST API context provider allows a user to get context data using RESTful API’s.	2
	SAP	This context provider performs GET operation on SAP OData service.	3
	SQL Server	Provides context/static data using XMPro Connector for SQL Server.	5
	Wonderware Historian	The stream object provides context/static data from Wonderware Historian database.	3
	XML File Reader	Reads values from an XML file using XPath queries.	2

Transformations

Icon	Transformation	Description	Tier
	Aggregate	Allows aggregate functions to be performed against a window of time in a stream.	5
	Batch Identifier	Allows a user to assign a unique identifier to a set of records.	5
	Broadcast	Splits a stream into multiple legs.	5
	Calculated Field	Allows the user to create new column values.	5
	Data Conversion	Allows the user to convert data type in another column.	5
	Edge Analysis	Enables identification and analysis of changes in a stream.	5
	Filter	Allows the user to filter a stream of data.	5
	Group and Merge	Allows the user to group by the specified column/s and merge the data of the selected columns.	5
	Join	Joins two streams.	5
	JSON Deserializer	Allows the user to convert a JSON string to JSON Array	5
	JSON Serializer	Allows the user to convert the selected input columns to a JSON string.	5
	Normalize Fields	Replaces non-identifier-friendly symbols from field names with their Unicode sequence.	5
	Pass Through	Allows the user to select or narrow down on a specific set of data points instead of pushing through all data points.	5
	Pivot Table	Performs a pivot on a table to perform analysis based on distinct instance values.	5
	Random Number	Calculates a random number within a range of 2 columns.	5
	Threshold Monitor	Detects when inputs exceeds or falls below a defined threshold.	5
	Transpose	Transposes a row’s values as columns or splits a column into a name and value columns.	5
	Union	This transformation performs a union operation on two streams.	5
	Window	Creates a Tumbling, Hopping, or Sliding window for a passing stream.	5

AI & Machine Learning

Icon	Function	Description	Tier
	Anomaly Detection	A deep learning R Script based implementation of Anomaly Detection model.	4
	Azure ML	Allows a stream to access an Azure Machine Learning model.	4
	Binary Classification	An algorithm to classify elements of a given set into two groups, then predict which group events will belong to.	4
	IBM Watson Machine Learning	This action agent allows you to execute IBM Watson Machine Learning model	4
	Jupyter Notebook – Python	This agent allows you to execute python script from Jupyter Notebook.	4
	Multi-class Classification	An algorithm to classify elements of a given set into three or more groups, then predict which group events will belong to.	4
	Predictive Model Markup Language (PMML)	Allows the user to perform Predictive Analytics using PMML Execution Engine.	4
	Python	This agent allows you to execute python script from a file.	4
	Regression	Predicts a numeric value based on past trends.	4
	RScript	A Function that runs user-created R language scripts.	4
	Sue	This agent uses the Sue Bot Web API.	4

Functions

Icon	Function	Description	Tier
	Convert Flow Units	Allows the user to convert between different fluid flow units.	5
	CRC16	Allows the user to calculate CRC16 values.	4
	FFT	Performs forward FFT calculation from input data.	4
	Min/Max	Returns the records that match the minimum/maximum value from grouped columns.	4
	Rounding	Allows the user to apply rounding to values based on specified precision.	4
	Signal Filter	Passes signals with a frequency that is lower or higher than the provided cutoff frequency.

Recommendations

Icon	Function	Description	Tier
	Read Recommendation	Read Recommendations from the XMPro App Designer.	5
	Recommendation Metrics	Provide metrics on Recommendations.	5
	Resolve Recommendation	Resolve a pending Recommendation.	5
	Run Recommendation	Run a Recommendation.	5
	Update Recommendation	Update pending Recommendation details.	5

Action Agents

Icon	Action Agent	Description	Tier
	ABB Ellipse – Work Order	This action agent allows you to create Work Order in ABB Ellipse system	3
	Amazon Firehose	Amazon Kinesis Firehose Action Agent that puts data into Firehose.	2
	Amazon Kinesis	Inserts data into an Amazon Kinesis Stream.	2
	Asset Administration Shell	This Agent allows updating AAS with live data.	2
	Azure Digital Twin	Updates an Azure Digital Twin with new data.	2
	Azure Event Hub	This action agent allows you to send data to Azure Event Hub.	2
	Azure Smart Contract	Performs actions on Azure Blockchain Smart Contracts.	2
	Azure SQL	An action agent to write data to Azure SQL database.	5
	Confluent Kafka	This action agent allows you to send data to Confluent Kafka platform.	2
	CSV Writer	This agent allows you to write data to a CSV file.	2
	Email	This action agent sends an email and allows email templating	5
	Ethereum Smart Contract	Fires Ethereum smart contract functions.	2
	Event Printer	Use this Agent to print events on Console.	5
	Fiix	This action agent allows you to create Work Order in Fiix CMMS system.	3
	GE Predix	Allows the user to perform REST operations of Assets and Time Series Services provided by GE Predix system.	3
	HP Vertica IoT	Writes data to an HP Vertica Database.	3
	IBM Maximo	This action agent allows you to insert records in IBM Maximo system.	3
	InfluxDB	This action agent allows you to write measurements into the configured InfluxDB.	2
	iPOS	An action agent to generate iPOS XML.	3
	MOVUS Events	This agent allows you to post actions/events to MOVUS Machine Cloud.	2
	MQTT	A generic MQTT action agent.	5
	MQTT Advanced	This agent allows you to send data to the configured MQTT system.	5
	MySQL	This agent allows you to write data to MySQL database.	2
	OData	This action agent performs POST, PUT and DELETE operations on an OData service.	2
	OPC DA Writer	This action agent writes new values to OPC DA entries.	2
	Oracle	The stream object inserts new data into an Oracle Server.	2
	OSIsoft	This agent allows you to update attribute values in OSIsoft PI system.	3
	Planner Create Task	This action agent allows you to create tasks in Microsoft Planner.	2
	Planner Update Task	This action agent allows you to update tasks in Microsoft Planner.	2
	REST API	The REST API action agent allows a user to perform operations using RESTful API’s	2
	SAP	This action agent performs GET and POST operations on SAP OData service.	3
	Salesforce	This action agent allows you to create new records for selected object in Salesforce.	3
	SQL Server Writer	An action agent to write data to a SQL server database.	5
	Twilio SMS	Sends SMS messages to mobile numbers.	5
	Wonderware Historian	This action agent allows you to write tag data to Wonderware Historian database.	3
	XMPro App	This action agent sends live data to an XMPro app page.	5