Stream SCADA can communicate to any MQTT broker (or server). Typical scenario when you have devices that are connected to an MQTT broker and you want to interact with these devices using Stream SCADA.


From Stream Explorer, select Data Sources and click on the Add button.


Main Tab:



  • Name: Unique name for the data source.
  • Description: Optional information about the data source.
  • Data Source Type: Selecting MQTT means that Stream SCADA is a client that will subscribe to an MQTT broker.


There are 2 steps to define connection with a MQTT broker.


Step 1: Connection


How to manage connections?


1. Click on "Manage".



2. Add a new connection using the + button. Enter the following details:

  • Name: Enter any valid unique name to identify this connection.
  • Active: Set to True (False will disable this connection).


  • UserName: MQTT broker user name.
  • Password: MQTT broker password.


  • BrokerAddress: IP or domain name of MQTT broker.
  • Port: IP or domain name of MQTT broker.
  • ClientID: (Optional)  Stream SCADA will use this ID when subscribing to the MQTT broker.
  • Topics: Enter one or more topic names to subscribe to (Separated with Semi column ";").




Step 2: Msg Format


How to manage message formats?


1. Click on "Manage".


2. Add a new message format using the + button. Enter the following details:

  • Name: Enter any valid unique name to identify this format.
  • Format: Select one of the available options:
    • Default: Used for native Stream Tags via MQTT Broker.
    • Wago_PFC: Used to connect o Wago PFC controllers via MQTT Broker.
    • Custom: Used as a generic parser for any Json message.

Note: If "Custom" is selected, it's mandatory to fill the section "Message (Custom Details)".

  • TagAddress_Path: The path in Json string to reach the name of the topic
  • TagValue_Path: The path in Json string to reach the value of the topic
  • TimeStamp_Path: The path in Json string to reach the timestamp of the change.


  • TimeFormat: Select the proper option that represents the timestamp in the json message.