اتصال پایتون و Node.js به بروکر MQTT

pip install paho-mqtt

import json
import paho.mqtt.client as mqtt

USER = "alice"
CLIENT_ID = "py-01"  # registered in the dashboard

def on_connect(client, userdata, flags, reason_code, properties):
    print("connected:", reason_code)
    client.subscribe(f"{USER}/sensors/#", qos=1)

def on_message(client, userdata, msg):
    print(msg.topic, msg.payload.decode())

client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, client_id=CLIENT_ID)
client.username_pw_set(USER, "YOUR_PASSWORD")
client.tls_set()
client.on_connect = on_connect
client.on_message = on_message

client.connect("mqtt.mqttcloud.ir", 8883, keepalive=60)
client.loop_start()
client.publish(f"{USER}/sensors/temp", json.dumps({"c": 24.8}), qos=1)

npm install mqtt

import mqtt from "mqtt";

const USER = "alice";
const client = mqtt.connect("mqtts://mqtt.mqttcloud.ir:8883", {
  clientId: "node-01", // registered in the dashboard
  username: USER,
  password: process.env.MQTT_PASSWORD,
});

client.on("connect", () => {
  client.subscribe(`${USER}/sensors/#`, { qos: 1 });
  client.publish(`${USER}/sensors/temp`, JSON.stringify({ c: 24.8 }), { qos: 1 });
});

client.on("message", (topic, payload) => console.log(topic, payload.toString()));
client.on("error", (err) => console.error(err.message));

const client = mqtt.connect("wss://mqtt.mqttcloud.ir/mqtt", {
  clientId: "web-01",
  username: "alice",
  password: "...",
});