Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

title:

...

"MQTT

...

Discovery Services — Connect, Browse, and Build Asset Navigation" tags: [mqtt, discovery-services, tagprovider, sparkplugb, asset-navigation,

...

dynamic-tags

...

, uns, iiot, datagrid, trendchart] description:

...

"Connect

...

FrameworX to

...

an

...

MQTT

...

broker

...

via

...

Discovery Services,

...

explore

...

its

...

namespace with the built-in MQTT browser,

...

link

...

data into

...

the

...

AssetTree,

...

and

...

build

...

a dynamic asset-navigation

...

UI

...

with

...

DataGrid,

...

TrendChart,

...

and

...

AlarmViewer

...

...

all

...

driven

...

by

...

Asset()

...

bindings."

...

version:

...

"1.0

...

"

...

author:

...

"Tatsoft"

...

...

MQTT Discovery Services — Connect, Browse, and Build Asset Navigation

This skill walks through a complete MQTT Discovery Services integration: connecting to a broker, exploring its topic tree, linking data into the UNS AssetTree, and building a dynamic asset-navigation UI where selecting a tree node changes all displayed data.

Prerequisite skill: Read skill-discovery-services first if you don't understand the difference between Device Module, DataLink, and Dynamic Tags.

When to Use This Skill

Use when:

  • The user wants to connect to an MQTT broker (external or built-in) using Discovery Services
  • The data structure is dynamic or unknown upfront — the broker defines what exists
  • The user mentions MQTT TagProvider, SparkplugB, IIoT, broker connection, or topic discovery
  • The user wants an asset-navigation UI where selecting a tree node changes displayed data
  • The application is monitoring/visualization focused

Do NOT use when:

  • The user wants explicit point-by-point control over specific MQTT topics with alarms on each — use Device Module with MQTT protocol (Channel → Node → Points)
  • The data source is not MQTT (for OPC UA Discovery Services, similar patterns apply but connection details differ — adapt from this skill)
  • The user just needs simulated data — use ValueSimulator with standard Tags

Prerequisites

  • Solution must be open (open_solution or create_solution completed)
  • An MQTT broker must be accessible (local or remote)
  • For testing: FrameworX has a built-in MQTT broker and a SparkplugB simulator

Implementation Steps

Step 0: Prepare the MQTT Broker (Testing or Production)

Option A: Built-in broker for testing/demo

Navigate to Data Explorer → MQTT Tools and start the built-in services:

designer_action('navigate', 'DataExplorer.MQTTTools')

From MQTT Tools, start the built-in broker and simulator using the tab actions:

designer_action('builtin_broker', 'start')
designer_action('builtin_simulator', 'start')

This creates a local MQTT broker on localhost:1883 and a SparkplugB simulator publishing sample data (solar panels, cities, sensors).

Option B: External production broker

Ask the user for:

  • Broker address and port
  • Authentication (username/password if needed)
  • TLS requirements
  • Whether the broker uses standard MQTT topics or SparkplugB

Step 1: Create the Discovery Services Connection

First, get the protocol schema to understand the PrimaryStation format:

get_table_schema('UnsTagProviders')
list_protocols('mqtt')

PrimaryStation format for MQTT — 14 semicolon-separated fields:

{Host};{Port};{ClientID};{Username};{Password};{CertFile};{KeyFile};{TLS};{CleanSession};{WillTopic};{QoS};{KeepAlive};{RetainPublish};{UseWebSocket};

Common configurations:

ScenarioPrimaryStation
Local built-in brokerlocalhost;1883;FrameworX-001;;;;;None;False;;AtLeastOnce;10;False;False;
Remote brokermqtt.factory.local;1883;FrameworX-001;;;;;None;False;;AtLeastOnce;10;False;False;
With authenticationbroker.cloud.io;8883;MyClient;admin;password123;;;TLS 1.2;False;;AtLeastOnce;30;False;False;
WebSocket connectionbroker.example.com;8083;MyClient;;;;;None;False;;AtLeastOnce;10;False;True;

Write the connection:

{
  "table_type": "

...

UnsTagProviders",
  "data": [

...

{

...

    "Name": "

...

MQTT",

...

    "

...

Protocol": "

...

MQTT",

...

    "

...

PrimaryStation": 

...

"localhost;1883;FrameworX-001;;;;;None;False;;AtLeastOnce;10;False;False;",

...

    

...

"

...

Separators": "

...

BranchSeparator=/;AttributeSeparator=/;",

...

    

...

"

...

Description": 

...

"Production MQTT 

...

Broker"
  }]
}

For SparkplugB brokers, use MQTTspB protocol instead:

{
  

...

"Name": "SparkplugBroker",
  "

...

Protocol": "

...

MQTTspB",

...

  

...

"

...

PrimaryStation": "

...

localhost;1883;FrameworX-SpB;;;;;None;False;;AtLeastOnce;10;False;False;",

...

  

...

"

...

Separators": 

...

"BranchSeparator=/;AttributeSeparator=/;",
  "Description": "SparkplugB broker with 

...

richer metadata"
}

Naming decision: The Name becomes the root of the dynamic namespace — all discovered topics appear under Tag.<Name>.*. Choose a meaningful name: ProductionMQTT, FactoryBroker, EdgeGateway, etc.

Separators: BranchSeparator=/;AttributeSeparator=/; maps MQTT topic hierarchy to UNS path hierarchy. This is almost always correct for MQTT.

Step 2: Link to AssetTree

Create an AssetTree folder that links to the Discovery Services connection. This makes the data navigable in the AssetsTree UI control.

get_table_schema('UnsAssetTree')
{
  "table_type": "UnsAssetTree",
  "data": [{
    "Name": "Production/MQTTData",
    "TagProviderLink": "MQTT",
    "InitialBranch": "spBv1.0/GroupID",
    "Description": "MQTT production data"
  }]
}

Key fields:

  • Name — the folder path in the AssetTree. Users see this in the navigation tree.
  • TagProviderLink — must match the Discovery Services connection Name from Step 1 exactly.
  • InitialBranch — the starting node in the broker's topic tree. Everything below this path auto-expands into the folder. If empty, the entire broker namespace is linked.

From this folder down, the tree is dynamic — no further configuration needed.

Step 3: Build the Layout

The standard asset-navigation pattern uses a Layout with three regions: Header (top), Menu (left side with AssetTree), and Content (main area).

get_table_schema('DisplaysLayouts')
list_elements('Layout')

Read the existing startup layout first to understand current structure:

get_objects('DisplaysLayouts', detail='full', names=['Startup'])

Write or modify the layout:

{
  "table_type": "DisplaysLayouts",
  "data": [{
    "Name": "Startup",
    "Description": "Asset navigation — tree on left, dynamic content on right",
    "Members": [
      {"Region": "Header", "Docking": "Top", "Page": "Display.Header"},
      {"Region": "Menu", "Docking": "Left", "

...

Page": "

...

Display.AssetNav"},
      {"Region": "Content", "Page": "Display.MainPage"}

...


    ]
  

...

}]
}

Note: Startup (layout ID 0) is the predefined startup layout — it loads on application launch. Read it first before modifying to preserve any existing configuration.

Step 4: Create the Header Display

A simple Canvas display with the application title and optional navigation buttons:

get_table_schema('DisplaysList')
list_elements('TextBlock,IndustrialIcon')
{
  "table_type": "DisplaysList",
  "data": [{
    "Type": "Display",
    "Name": "Header",
    "PanelType": "Canvas",
    "DisplayMode": "Page",
    "Width": 1200,
    "Height": 60,
    "Description": "Application header bar",
    "Elements": [
      {
        "Type": "TextBlock",
        "Name": "Title",
        "Left": 20,
        "Top": 15,
        "Text": "MQTT Production Monitor",
        "FontSize": 18,
        "FontWeight": "Bold"
      }
    ]
  }]
}

Use themed colors from list_elements('ThemeColors') instead of hardcoded hex values.

Step 5: Create the AssetTree Navigation Display

A Canvas display containing the AssetsTree control. When users click nodes, the platform updates Client.Context properties automatically.

list_elements('AssetsTree')
{
  "table_type": "DisplaysList",
  "data": [{
    "Type": "Display",
    "Name": "AssetNav",
    "PanelType": "Canvas",
    "DisplayMode": "Page",
    "Width": 300,
    "Height": 700,
    "Description": "Asset tree navigation panel",
    "Elements": [
      {
        "Type": "AssetsTree",
        "Name": "NavTree",
        "Left": 0,
        "Top": 0,
        "Width": 300,
        "Height": 700
      }
    ]
  }]
}

What happens when the user clicks a node:

PropertyDescriptionExample value
Client.Context.AssetPathFull path of selected nodeMQTT/spBv1.0/GroupID/Barcelona/Panel1
Client.Context.AssetNameDisplay name of selected nodePanel1
Client.Context.AssetNodeNameLeaf node namePanel1
Client.Context.SelectedTagFull tag path if a tag is selectedtag path string

These properties drive the content display reactively — all elements bound to them update automatically.

Step 6: Create the MainPage (Dynamic Content)

The MainPage uses Asset() bindings and Client.Context to react to the user's tree selection. One display serves the entire asset hierarchy.

list_elements('DataGrid,TrendChart,TextBlock,AlarmViewer')

Dashboard layout approach:

{
  "table_type": "DisplaysList",
  "data": [{
    "Type": "Display",
    "Name": "MainPage",
    "PanelType": "Dashboard",
    "Columns": 2,
    "Rows": 3,
    "Description": "Dynamic content — reacts to AssetTree selection",
    "Elements": [
      {
        "Type": "TextBlock",
        "Name": "AssetTitle",
        "Row": 0,
        "Column": 0,
        "ColumnSpan": 2,
        "Text": "",
        "LinkedValue": "@Client.Context.AssetName",
        "FontSize": 20,
        "FontWeight": "Bold"
      },
      {
        "Type": "DataGrid",
        "Name": "AssetData",
        "Row": 1,
        "Column": 0,
        "ColumnSpan": 2,
        "Height": 300
      },
      {
        "Type": "TrendChart",
        "Name": "AssetTrend",
        "Row": 2,
        "Column": 0,
        "Height": 250,
        "Duration": "00:05:00"
      },
      {
        "Type": "AlarmViewer",
        "Name": "AssetAlarms",
        "Row": 2,
        "Column": 1,
        "Height": 250
      }
    ]
  }]
}

The key pattern — DataGrid bound to context:

The DataGrid displays all children (sub-tags and attributes) of whatever the user selected in the AssetTree. Check list_elements('DataGrid') for the exact property names to bind the DataGrid to Client.Context.AssetPath. The DataGrid automatically shows all tags below the selected path.

Asset() in CodeBehind (display events):

Public Sub DisplayOpening()
    ' Optionally set a default branch to expand on load
    @Client.Context.TreeInitialBranch = "MQTT/spBv1.0/GroupID"
End Sub

Step 7: Start Runtime and Verify

designer_action('start_runtime')

After starting:

  1. The Discovery Services connection contacts the MQTT broker and discovers topics
  2. The AssetTree populates with the linked folder structure
  3. Clicking any node updates Client.Context properties
  4. DataGrid, TrendChart, and other elements react to the selection

Take a screenshot to verify:

get_screenshot(target='runtime')

MQTT vs SparkplugB — Which Protocol?

AspectMQTT (standard)MQTTspB (SparkplugB)
Protocol name in FrameworXMQTTMQTTspB
Topic structureFlat or custom hierarchy`spBv1.0/GroupID/NBIRTH
MetadataTopic names onlyRich: data types, birth/death certificates, metrics
Discovery qualityBasic (topic tree)Full (typed variables with descriptions)
When to useGeneric MQTT brokers, custom topic schemesIndustrial IoT with SparkplugB-compliant edge nodes

If the broker publishes SparkplugB messages, always prefer MQTTspB — you get typed variables and richer metadata.

Variations

Variation A: Built-in Broker as Data Hub

Use FrameworX's built-in MQTT broker as a central data hub. External devices publish to it, and the Discovery Services connection reads from it — all on localhost.

{
  "Name": "LocalHub",
  "Protocol": "MQTT",
  "PrimaryStation": "localhost;1883;FrameworX-Hub;;;;;None;False;;AtLeastOnce;10;False;False;",
  "Separators": "BranchSeparator=/;AttributeSeparator=/;",
  "Description": "Built-in broker as central data hub"
}

Start the built-in broker from Runtime Startup or via designer_action('builtin_broker', 'start').

Variation B: Multiple Brokers

Create multiple Discovery Services connections, each with a different Name:

{
  "table_type": "UnsTagProviders",
  "data": [
    {"Name": "FactoryA", "Protocol": "MQTT", "PrimaryStation": "mqtt-a.factory.com;1883;..."},
    {"Name": "FactoryB", "Protocol": "MQTT", "PrimaryStation": "mqtt-b.factory.com;1883;..."}
  ]
}

Create separate AssetTree folders for each. The same Layout and MainPage pattern works — Client.Context handles any source.

Variation C: Hybrid — Dynamic Browsing + DataLink for Critical Points

Use Discovery Services for browsing the full MQTT namespace, but create local tags with DataLink for the few points that need alarms and historian:

{
  "table_type": "UnsTags",
  "data": [
    {
      "Name": "Critical/ReactorTemp",
      "DataType": "Float",
      "DataLink": "/MQTT/plant/reactor/temperature",
      "Min": 0,
      "Max": 500,
      "Description": "Reactor temperature — alarmed and historized"
    }
  ]
}

Then configure alarms and historian on Critical/ReactorTemp as a normal tag. The DataLink binds it to the MQTT path automatically.

Variation D: Add Historian Queries to TrendCharts

If connecting to a historian-capable Discovery Services connection (Canary, InfluxDB, etc.), TrendCharts using Asset() syntax automatically query historical data for the selected time range. Configure the Discovery Services connection with IsHistorian: true.

Common Pitfalls

MistakeWhy it happensHow to avoid
Creating local UnsTags for MQTT dataHabit from Device Module workflowDynamic tags don't need local tags. Only use DataLink for points needing alarms/historian.
Wrong PrimaryStation formatForgetting semicolons or field orderAlways call list_protocols('mqtt') first. The format is 14 semicolon-separated fields.
Topics with special chars not accessibleMQTT topics like spBv1.0/Group contain dotsUse quoted Asset() syntax: Asset("/ProviderName/spBv1.0/Group/Node")
AssetTree empty after runtime startConnection not established or linked folder misconfiguredCheck Services Monitor for connection status. Verify TagProviderLink matches the connection Name exactly.
Using MQTT protocol for SparkplugB brokerSparkplugB has specific message formatUse MQTTspB protocol for SparkplugB brokers — you get typed variables and metadata.
DataGrid shows nothingNot bound to Client.Context properlyCheck list_elements('DataGrid') for the correct binding properties.
Trying to set alarms on dynamic tagsNo local tag exists for dynamic dataCreate a local tag with DataLink for that specific path, then configure alarms on it.

Quick Reference — MCP Tool Calls

TaskTool call
Get MQTT protocol formatlist_protocols('mqtt')
Get SparkplugB formatlist_protocols('mqtt sparkplug')
Create Discovery Services connectionwrite_objects('UnsTagProviders', data=[...])
Create AssetTree linked folderwrite_objects('UnsAssetTree', data=[...])
Browse AssetsTree element schemalist_elements('AssetsTree')
Browse DataGrid schemalist_elements('DataGrid')
Navigate to MQTT Toolsdesigner_action('navigate', 'DataExplorer.MQTTTools')
Start built-in brokerdesigner_action('builtin_broker', 'start')
Start built-in simulatordesigner_action('builtin_simulator', 'start')
Check runtime stateget_state(target='runtime')
Navigate to Services Monitordesigner_action('navigate', 'ServicesMonitor')

Related Skills

  • skill-discovery-services — Conceptual foundation: three connection patterns, DataLink, Asset() syntax, when to use what
  • skill-display-construction — General display building patterns (Canvas/Dashboard, themed colors, element placement)

Documentation References