Updated May 2025

Crosser Module Library

This document presents the currently available standard modules for use with the Crosser Node.

The module library is constantly expanded with new modules. New modules are typically developed in a time frame of days to weeks, either by Crosser, partners or end customers. Please contact Crosser to discuss availability of any missing modules.

Input modules

Name	Description
Array Batch	Splits an incoming array property into multiple messages, each containing a batch of items.
Aveva Historian Reader	Get time series data from an Aveva Historian.
AVEVA Unified Engineering Reader	Enables reading data from AVEVA Unified Engineering tables via the AVEVA Integration Services API.
AVEVA Unified Engineering Subscriber	Connects to AVEVA Unified Engineering servers to subscribe to real-time data sources and forward the received data through the Crosser flow.
Azure IoT Edge Hub Receiver	Receive data from the Azure IoT Edge hub (this requires the Crosser Edge node to be hosted on an IoT Edge device).
Azure IoT Hub C2D	Receive data from Azure IoT hub.
Azure Event Hubs Consumer	Recieves data from Azure Event Hubs
BigMarker Search Conferences	Find web conferences in BigMarker.
BigMarker Conference Registrations	Find registered users in a BigMarker web conference.
BigMarker Conference Attendees	Find user attendees in a BigMarker web conference.
CAN Raw Reader	Get raw data from CAN bus (Linux systems only).
Couchbase Executer	Get data from a Couchbase database by running generic queries.
CSV Reader	Read data from a local CSV file.
Data Trigger	Collects messages and creates an output based on a defined list of trigger definition conditions.
File Finder	Finds files in a local directory matching some criteria.
File Tail Reader	Get lines added to a file.
File Reader	Reads text or bytes from a file into a property and passes it to the next module(s).
Files Watcher	Watch for events on files matching a pattern (Created, Deleted, Changed).
Firebird Select	Get rows from a Firebird database.
Google PubSub Subscriber	Subscribe to data from Google PubSub.
Google Sheet Read Rows	Get rows from a Google Sheet document.
HTTP Listener	Receive data over HTTP POST or GET. Filter on path.
HTTP Requester	Request data from HTTP servers at regular intervals.
HTTP Response	Write a HTTP response back to a requesting client.
HubSpot CRM Search	Search for records in Hubspot CRM.
Influx Select	Get time series data from an Influx database.
Interval	Trigger a message at specified intervals.
If Else Condition	Add if/else conditions to split/route messages to different outputs.
Kafka Consumer	Will consume messages from Kafka
KeyValue Get	Get data from the internal key/value store.
Kubernetes Events	Get events from a Kubernetes namespace.
MariaDB Executer	Execute generic SQL statements against a MariaDB SQL server.
MariaDB Select	Get data from a MariaDB SQL server table based on a SELECT query.
Modbus Reader	Request data from Modbus PLCs at specified intervals. Provides configurable mapping to more complex data types.
MongoDB Select	Get data from a MongoDB database.
MQTT Sub broker	Get data from the internal MQTT broker. Filter on topics.
MQTT Sub client	Get data from an external MQTT broker. Filter on topics.
Microsoft Dynamics Get Records	Get records from a Microsoft Dynamics server.
Microsoft Excel Reader	Reads data from Microsoft Excel files (.xlsx, .xls) and outputs each row as a separate message in the Crosser flow.
MS SQL Executer	Execute generic SQL statements against a Microsoft SQL server.
MS SQL Select	Get data from a Microsoft SQL server table based on a SELECT query.
MS SQL Stored Procedure	Get data from a Microsoft SQL server by triggering a stored procedure.
MS Teams List Chats	List chats in Microsoft Teams to get their IDs.
MySQL Executer	Execute generic SQL statements against a MySQL server.
MySQL Select	Get data from a MySQL server table based on a SELECT query.
OPC UA Browser	Collects a list of all node IDs/tags with value attributes below a specified root level on an OPC UA server.
OPC UA Events	Get events from an OPC UA server.
OPC UA Reader	Get data from OPC UA servers by polling all configured tags when triggered. Tags can be given friendly names.
OPC UA Subscriber	Get data from OPC UA servers by subscribing to a specified list of nodeIds/tags. Receives data when any of the subscribed tags change value. Custom properties can be added to each tag.
Oracle DB Select	Get data from a Oracle database table based on a SELECT query.
OSIsoft WebAPI Subscriber	Subscribe to changes in PI points on a OSIsoft server.
Postgres Executer	Execute generic SQL statements against aPostgreSQL server.
PostgreSQL Select	Get rows from a PostgreSQL database table.
PostgreSQL CDC Receiver	Captures and processes change data capture (CDC) events from a PostgreSQL database
RabbitMQ Consumer	Get messages from a RabbitMQ broker.
Redis Get	Lookup a value in a Redis store by using data from the incoming message as key.
Redis Subscribe	Subscribe to a topic in a Redis store.
Resource Loader	Allow resources of types File, Python Script and C# script to be selected through parameter overrides
Rockwell Data Table Receiver	Receives data from a Data Table write operation on a Rockwell PLC.
Rockwell Reader	Get data from Rockwell (Allen Bradley) PLCs.
S7 OUC Receiver	Get data from Siemens PLCs using the Open User Communication protocol.
S7 Reader	Get data from Siemens S7-200, 300, 400, 1200 and 1500 PLCs.
Salesforce Get Record	Get a record from Salesforce based on ID.
Salesforce Search Records	Free-text search of records in Salesforce.
Salesforce SOQL Query	Find records by executing a SOQL query in Salesforce.
SAP RFC	Call any RFC/ABAP/BAPI function on an SAP system using Netweaver. Supports both reading and writing data.
Scheduler	Trigger repetitive events based on wall-clock time patterns (cf *nix `cron` command).
SFTP Directory Reader	List files in a directory on a remote SFTP server.
SFTP Download	Download files from FTP servers to local storage.
SFTP Files Watcher	Check for updates on FTP servers.
SFTP Text Reader	Get files from a FTP server.
SNMP Get	Get OIDs from an SNMP server.
Snowflake Executer	Run generic queries against a Snowflake database.
Snowflake Select	Get rows from a Snowflake database.
TCP Client Listener	Connect to a TCP server and receive raw data on a specified port.
TCP Listener	Receive data over a TCP connection.
TimescaleDB Select	Get time series data from a TimescaleDB database.
UDP Multicast Receiver	Receive data from UDP multicast.
UDP Unicast Receiver	Receive data from UDP unicast.
Websocket Listener	Receive data over websocket connections.
Zoho Desk Search Tickets	Search for tickets in Zoho Desk.

Analytics modules

Name	Description
Aggregate	Aggregate data over a time period or a number of samples. Group data per source label. Calculates average, min and max.
Array Groupby	Group array elements into sub-arrays based on the value of a selected property.
Array Join	Combine multiple messages into an array, either by collecting messages during a specified time window, or a specified number of messages.
Array Property Get	Get one property for each object in an array and creates a new array, with only the values of the properties.
Array Property Omit	Omits properties from all objects in an array of objects and creates a new array with objects without the omitted properties.
Array Property Pick	Picks properties from all objects in an array of objects and creates a new array with objects containing only the picked properties.
Array Regex	Select a subset of an array by checking a selected property in each element against a regex filter.
Array Sort by List	Sort the elements of an array of objects by providing a list of values matching a selected property.
Array Sort by Property	Sort an array based on the value of a selected property.
Array Split	Splits an array into individual messages.
Array To Object	Convert an array of name/value properties into a flat object.
Base64 Decode	Decode a base64 encoded string.
Base64 Encode	Encode a byte array or string as base64 or base64url strings.
CAN J1939 Decoder	Decode raw can messages using a DBC file.
Csharp	Process message data using custom C# code.
CSV LineParser	Splits a single line of CSV into an object.
CSV TextParser	Parses CSV text into an array of objects.
Data Mapper	Transform messages using a visual configuration tool.
Deadband	Deadband filter that only lets through data that has changed by a certain amount (absolute or relative).
Delay	Delay messages during a specified time period.
Files Delete	Delete files matching a pattern.
Files Move	Move files matching a pattern.
IronPython	Process message data using custom Python code. This module uses the IronPython interpreter that runs within the .NET core environment. Therefore only the standard Python libraries can be used. This interpreter is compatible with Python 2.7. See the Python Bridge module for other Python options.
Javascript	Process message data using Javascript code.
JSON Schema Validation	Validate message data against a JSON schema
Join	Join multiple messages arriving from different sources into a single message. Messages can be aligned in time. Different modes are available to handle data with different sampling rates.
JSON	Converts to/from JSON and the internal data representation.
Key Value Delete	Delete an entry from the internal key/value store.
Math Expression	Evaluate generic mathematical expressions on message data.
Math	Evaluate generic mathematical expression on message data
Memory Buffer	Buffers messages in front of output modules so that no data is lost even if the availability of external systems is intermittent, e.g. due to connectivity issues. The buffer size is configurable. Supports configurable retries by looking at the status property delivered by all output modules. Can also be used to smooth out bursty message flows by specifying a message delay.
Message Counter	Calculate statistics on message value counts (eg for KPI calculations).
Object To Array	Converts an object with key=value properties to an array of objects with separate name and value properties.
Property Mapper	Renames properties on incoming messages. Can also be used to remove unwanted properties from messages.
Python Bridge	Process message data using custom Python code. This module uses a standard Python 3 interpreter running outside .NET core, hence any library can be used.
Range Classifier	Map numerical ranges of a property on the incoming message to text strings added to the output messages.
Range Filter	Only let through messages where some numerical parameter is either within or outside a specified range. Note: This functionality is also available using the message filters present on all modules.
Report By Exception	Only let through messages where a selected parameter has changed. Supports grouping over multiple source labels.
Scale	Scale a numerical value and/or add an offset.
Smooth	Smooth numerical data by applying either an exponential filter or by averaging over a rolling time window.
Split	Split messages onto separate paths by defining conditions on message data.
State	Temporarily store any message property. Used to keep data that is updated infrequently but needs to be added to more frequent messages.
Statistics	Calculates statistics on selected data over a rolling window, specified either by time or by number of samples. Supports grouping over multiple source labels. Outputs average, median, standard deviation, min, max and sample count. This module will eventually replace the Standard Deviation module.
String Replace	Replace text on a selected property in a message.
String Substring	Extract a substring of a string on a selected property.
Text Template	Create a text message based on a template that uses data from the incoming message.
Throttle	Limit the peak rate of messages by discarding messages when the specified peak rate is reached.
Time Counter	Calculate statistics on message value times (eg for KPI calculations).
Time Difference	Calculate the difference between timestamps.
Timeout	Generate a message when no message (fulfilling some condition) has been received within the specified timeout period. Can be used to detect loss of connectivity with a sensor or other data source.
Timestamp	Converts between timestamp formats and can also add the current time to an incoming message.
Toggle	Toggle the value of a boolean property.
Unique Counter	Count the number of different values seen on a selected property of the incoming message.
Window	Create sliding and tumbling windows (arrays) out of a sequence of messages.
XML	Converts to/from XML and the internal data format.

Output modules

Name	Description
AVEVA Unified Engineering Publisher	Publishes flow message data to AVEVA Unified Engineering (UE) tables through the AVEVA Integration Services API.
AWS IoT Core Publisher	Publish message or update shadow state of an AWS 'Thing'.
AWS IoT Core HTTP Publisher	Publishes messages over HTTP.
AWS S3 Bucket Writer	Send files to an AWS S3 bucket.
Azure Blob Storage	Add blobs to Azure blob storage. The source can be a file, string or byte array. Three types of blobs are supported: append, page and block blobs.
Azure DataLake Writer	Add files to Azure DataLake gen2 storage. The source can be files, strings or byte arrays.
Azure Event Hubs Publisher	Publishes message data to Azure Event Hubs.
Azure Event Grid Publisher	Publishes message data to Azure Event Grid.
Azure File Storage	Send data to Azure file storage. The source can be a file, files, strings or byte arrays.
Azure IoT Edge Hub Sender	Send data to the Azure IoT Edge hub (this requires the Crosser Edge node to be hosted on an IoT Edge device).
Azure IoT Hub D2C	Send data to Azure IoT Hub.
Azure Queue Storage	Send data to an Azure Queue storage.
BigQuery Insert	Send data to a Google BigQuery table.
CAN Raw Writer	Send raw data to a CAN bus (Linux only).
CSV StreamWriter	Append data to CSV files and rotate on time or number of rows.
Databricks Publisher	Transfer files from a staging area to a Databricks delta table.
File StreamWriter	Appends message data to a file on the local file system. (used to be called File Writer).
File Writer	Writes the content of the source property to a file.
Firebird Insert	Write data to a Firebird database.
Google Cloud Storage Writer	Writes data to Google Cloud storage.
Google PubSub Publisher	Send data to Google PubSub.
Google Sheet Append Row	Append rows to a Google Sheet.
HTTP Requester	Send data to HTTP servers using POST/PUT requests.
HubSpot CRM Create	Create a record in Hubspot CRM.
HubSpot CRM Delete	Delete a record in Hubspot CRM.
HubSpot CRM Update	Update a record in Hubspot CRM.
IFS Observation Publisher	Send observations to IFS ERP systems.
InfluxDB Insert	Write data to an InfluxDB version 1 database.
InfluxDB v2 Insert	Write data to an InfluxDB version 2 database.
Kafka Producer	Publish data on a Kafka topic.
Key Value Set	Store data in the internal key/value store.
MariaDB Insert	Write data to a MariaDB server table.
Modbus Writer	Write data to a Modbus PLC.
MongoDB Insert	Write data to a MongoDB database.
MQTT Pub broker	Send data to the internal MQTT broker.
MQTT Pub client	Send data to an external MQTT broker.
Microsoft Dynamics Create Record	Create records in a Microsoft Dynamics server.
MS SQL Insert	Write data to a Microsoft SQL server table.
MS Teams Send Chat	Send messages to a Microsoft Teams chat.
Microsoft Teams Send	Send messages to a Microsoft Teams channel.
MySQL Insert	Write data to a MySQL server table.
Nexmo SMS	Send an SMS using the Nexmo service.
OPC UA Writer	Update values in an OPC UA server.
Oracle DB Insert	Write data to an Oracle database table.
Parquet Writer Module	Write data to a Parquet file.
PostgreSQL Insert	Write rows to a PostgreSQL database table.
RabbitMQ Producer	Publish messages to a RabbitMQ broker.
Redis Publish	Publish data on a topic in a Redis store.
Redis Set	Set or update a key/value in a Redis cache.
S7 Writer	Write data to Siemens S7-200, 300, 400, 1200 and 1500 PLCs.
Salesforce Create Record	Create a new record in Salesforce.
Salesforce Update Record	Update an existing record in Salesforce.
SendGrid	Send an email using the SendGrid service.
SFTP Upload	Upload a local file to an FTP server.
SIGNL4 Publisher	Publish data to SIGNL4.
Slack	Send a message to a Slack channel.
SMTP Send	Send emails using an SMTP server.
Snowflake Insert	Write data to Snowflake.
Snowflake Publisher	Transfer data from a staging area to a Snowflake database.
Snowflake Streaming Publisher	Streams data directly to Snowflake tables in real-time using the high-performance Snowpipe Streaming API.
Thingworx Publisher	Send data to Thingworx by updating properties on a Thing.
TimescaleDB Insert	Write timeseries data to a TimescaleDB database.
Twilio SMS	Send SMS messages using the Twilio service.
UDP Multicast Sender	Send data over UDP multicast.
UDP Unicast Sender	Send data over UDP unicast.
Websocket Publisher	Sends data to one or several websocket listeners that have subscribed to the specified topic.
Zendesk Ticket Create	Create tickets in Zendesk.
Zoho Desk Create Ticket	Create a new ticket in Zoho Desk.
Zoho Desk Update Ticket	Update a ticket in Zoho Desk.

Test modules

These modules are primarily useful for testing flows with internally generated data.

Name	Description
Data Generator	Generate messages based on a JSON template. Randomize numeric properties and generate sequences of string values over a group of messages.
Date Generator	Generates a random date between specified limits
Debug	Send data to the internal log
Random	Generates a random number in a given range
String Generator	Generates a random text string based on criteria given

Universal Connectors

This is a wizard-based tool with which you can build your own reusable modules for connecting to REST-based APIs. Using the step-by-step wizard you configure:

API endpoints
Authentication
User configurable parameters
Module icon
Documentation

API requests can use both user settings and data from incoming flow messages.

Modules built with the Universal Connector tool are only available to users within your organisation.

SDK modules

Using the Crosser .NET Core SDK you can develop your own custom modules, which can then be registered in Crosser Cloud to be used alongside the standard modules when building flows in the FlowStudio. Custom modules are only available to users in your organization.

If you want to know more about the SDK, check out the public documentation at https://sdk.crosser.io.

Search Documentation

Page Sections