Input modules

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 CONNECT flows.

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.

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.

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 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 and 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 have user friendly names.

OPC UA Subscriber

Get data from OPC UA servers by subscribing to a specified list of node IDs and 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 a PostgreSQL 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.

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.