[PYTHON] Versuchen Sie, Nifty Cloud MQTT von C4SA aus zu betreiben

Ich denke, es ist ziemlich schwierig, die Umgebung mit einer kleinen Bestätigung für den Betrieb vorzubereiten. Ich möchte die Umgebung einfach mit C4SA einstellen und Nifty Cloud MQTT betreiben.

Vorbereitung

Bitte schließen Sie die Registrierung bei C4SA im Voraus ab. Es kann 15 Tage lang kostenlos genutzt werden. Auf der Clientseite muss nur ein kompatibler Browser vorbereitet werden.

Machen Sie einen Abonnenten

Erstellen Sie eine Leinwand

Jetzt erstellen wir eine Zeichenfläche, auf der Python ausgeführt wird.

Klicken Sie auf Neuen Canvas erstellen und wählen Sie Python Campus.

Setzen Sie den Canvas-Namen auf "Subscriber".

Wenn die Erstellung abgeschlossen ist, können Sie sie in der Canvas-Liste ausführen.

Wenn Sie die Zeichenfläche öffnen, können Sie die erstellte Anwendung bedienen.

Installieren Sie die erforderlichen Module

C4SA verfügt über eine CLI-Funktion zum Installieren von Paketen usw. Diese Funktion installiert Paho für die Veröffentlichung von CLI in MQTT. Öffnen Sie die CLI und führen Sie den folgenden Befehl aus.

pip install paho-mqtt

Erstellen Sie eine Arbeitsquelle

Lesen Sie hier und legen Sie die Informationen für die Verbindung mit Nifty Cloud MQTT aus dem Beispiel fest. Verwenden Sie zum Erstellen der Quelle den Canvas-Editor.

Eine neue Datei wird erstellt. Klicken Sie daher auf die Schaltfläche Neu.

Nennen Sie die Datei "mqttsub.py".

Schreiben Sie im Editor die folgenden Dateien.

mqttsub.py

# coding=utf8

import paho.mqtt.client as mqtt

USERNAME = "[Administrator Benutzername]"
PASSWORD = "[Passwort]"

def on_connect(client, userdata, result):
    print("Connected with result code " + str(result))


def on_message(client, userdata, msg):
    print(msg.topic + " " + str(msg.payload))


if __name__ == '__main__':

    client = mqtt.Client()
    client.username_pw_set(USERNAME, PASSWORD)
    client.on_connect = on_connect
    client.on_message = on_message

    client.connect("[Domain]", [MQTT-Port])
    client.subscribe("topic/#")

    client.loop_forever()

Versuchen Sie, es zum Laufen zu bringen

Öffnen Sie die CLI erneut und führen Sie den folgenden Befehl aus:

python mqttsub.py

Der Bildschirm sieht wie folgt aus.

Als nächstes erstellen wir einen Publisher.

Machen Sie einen Bubbler

Erstellen Sie dann einen Client zum Veröffentlichen.

Einführung

Erstellen Sie eine Zeichenfläche und installieren Sie die erforderlichen Module auf die gleiche Weise.

Erstellen Sie eine Arbeitsquelle

Stellen Sie die Informationen für die Verbindung mit Nifty Cloud MQTT ein. Verwenden Sie zum Erstellen der Quelle den Canvas-Editor.

Setzen Sie den Canvas-Namen auf "Publisher".

Nennen Sie die Datei "mqttpub.py".

Schreiben Sie im Editor die folgenden Dateien.

mqttpub.py

# coding=utf8

import paho.mqtt.client as mqtt

USERNAME = "[Administrator Benutzername]"
PASSWORD = "[Passwort]"

if __name__ == '__main__':

    client = mqtt.Client()
    client.username_pw_set(USERNAME, PASSWORD)

    client.connect("[Domain]", [MQTT-Port])

    client.publish("topic", "C4SA test message")

Versuchen Sie, es zum Laufen zu bringen

Öffnen Sie die CLI erneut und führen Sie den folgenden Befehl aus:

python mqttpub.py

Werfen wir einen Blick auf die Leinwand des Abonnenten, die wir zuvor erstellt und gestartet haben.

Die von Ihnen gesendete Nachricht wird angezeigt.

Schließlich

Was haben Sie gedacht? Ich konnte den Nifty Cloud MQTT problemlos bedienen.