MQTT

MQTT (Message Queuing Telemetry Transport) is a lightweight, publish-subscribe based messaging protocol designed for low-bandwidth, high-latency, or unreliable network environments. It is widely used in the Internet of Things (IoT), mobile applications, and distributed systems to achieve efficient communication between devices. By reducing data transmission volume and simplifying the communication process, MQTT ensures reliable message delivery while supporting multiple Quality of Service (QoS) levels to meet different business needs.

Installation and Configuration¶

• MQTT Broker

Guance Cloud supports receiving MQTT protocol data through Func.

Install Func¶

We recommend enabling Guance Cloud Integration - Extensions - Managed Func: all prerequisites are automatically installed. Please proceed with the script installation.

If you deploy Func on your own, refer to Self-hosted Func Deployment

We recommend deploying the GSE version

FUNC has already implemented integration with MQTT data sources. Follow these steps to connect:

• 1 Write a Script

Write a script on Func to consume MQTT data

import json

@DFF.API('Message Handler')
def message_handler(topic, message):
    print(f"Received message: {message} on topic {topic}")

After writing the script, click the 【Publish】 button.

• 2 Configure MQTT Connector

① Select type as MQTT Broker (v5.0)

② Fill in ID, host, port

③ Topics and corresponding script for topic consumption

④ Click to test connectivity to ensure MQTT can connect normally

⑤ Click save