MQTT Connect Node

M

Web/MQTT

MQTT Connect

Connects to an MQTT broker and returns a session reference for use with Publish, Subscribe, and Disconnect nodes.

mqtt_connectweb

Inputs2

Outputs3

Security exposure4/10

Packageweb

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.

4/10Medium

PrivacyPotential sensitivity of processed data.

3/10High

PerformanceRuntime or resource pressure.

3/10High

GovernancePolicy, audit, or compliance impact.

5/10Medium

ReliabilityOperational stability considerations.

4/10Medium

CostExternal or compute cost impact.

1/10High

Input Pins

2

Execute

Execution

exec_in

Initiate the MQTT connection

Config

Struct

config

MQTT connection configuration (host, port, client_id, optional credentials, TLS)

SchemaMqttConfigMqttConfigMqttConfig8 fields

hoststringrequired

portinteger:uint16required

format uint16min 0max 65535

client_idstringrequired

usernamestring | null

default null

passwordstring | null

default null

keep_alive_secondsinteger:uint64

format uint64default 30min 0

use_tlsboolean

default false

tlsTlsConfig

default {"secure":false,"certificate":null,"ca_...

secureboolean

default false

certificateanyOf (2)

default null

variant 1TlsCertificatevariant

certificate_pemstringrequired

private_key_pemstringrequired

variant 2nullvariant

ca_certificate_pemstring | null

default null

server_namestring | null

default null

accept_invalid_certificatesboolean

default false

Schema enforced

Output Pins

3

Done

Execution

exec_out

Fires after the connection is established

Session

Struct

session

MQTT session reference for use with Publish/Subscribe/Disconnect nodes

SchemaMqttSessionMqttSessionMqttSession2 fields

ref_idstringrequired

client_idstringrequired

Schema enforced

Error

Execution

exec_error

Fires if the connection fails to establish

Node Info

Internal name

mqtt_connect

Category

Web/MQTT