[PYTHON] Essayez d'utiliser Nifty Cloud MQTT à partir de C4SA

Je pense qu'il est assez difficile de préparer l'environnement pour l'opération avec une petite confirmation. Je voudrais configurer facilement l'environnement avec C4SA et utiliser Nifty Cloud MQTT.

Préparation

Veuillez terminer l'enregistrement à C4SA à l'avance. Il peut être utilisé gratuitement pendant 15 jours. Il n'est pas nécessaire de préparer autre chose qu'un navigateur compatible côté client.

Faire un abonné

Créer une toile

Maintenant, créons un canevas qui exécute Python.

Cliquez sur Créer un nouveau canevas et sélectionnez Campus Python.

Définissez le nom du canevas sur "Abonné".

Lorsque la création est terminée, vous pouvez l'actionner dans la liste des canevas.

Lorsque vous ouvrez le canevas, vous pouvez utiliser l'application créée.

Installez les modules requis

C4SA a une fonction CLI pour installer des packages et ainsi de suite. Cette fonctionnalité installe Paho pour publier de CLI vers MQTT. Ouvrez la CLI et exécutez la commande suivante.

pip install paho-mqtt

Créer une source de travail

Reportez-vous à here et définissez les informations pour vous connecter à Nifty Cloud MQTT à partir de l'exemple. Pour créer la source, utilisez l'éditeur de canevas.

Un nouveau fichier sera créé, cliquez donc sur le nouveau bouton.

Nommez le fichier "mqttsub.py".

Dans l'éditeur, écrivez les fichiers suivants.

mqttsub.py

# coding=utf8

import paho.mqtt.client as mqtt

USERNAME = "[Nom d'utilisateur de l'administrateur]"
PASSWORD = "[mot de passe]"

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("[domaine]", [Port MQTT])
    client.subscribe("topic/#")

    client.loop_forever()

Essayez de le faire fonctionner

Rouvrez la CLI et exécutez la commande suivante:

python mqttsub.py

L'écran ressemblera à celui ci-dessous.

Ensuite, nous allons créer un éditeur.

Faire un barboteur

Créez ensuite un client à publier.

introduction

Créez un canevas et installez les modules requis de la même manière.

Créer une source de travail

Définissez les informations de connexion à Nifty Cloud MQTT. Pour créer la source, utilisez l'éditeur de canevas.

Définissez le nom du canevas sur "Publisher".

Nommez le fichier "mqttpub.py".

Dans l'éditeur, écrivez les fichiers suivants.

mqttpub.py

# coding=utf8

import paho.mqtt.client as mqtt

USERNAME = "[Nom d'utilisateur de l'administrateur]"
PASSWORD = "[mot de passe]"

if __name__ == '__main__':

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

    client.connect("[domaine]", [Port MQTT])

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

Essayez de le faire fonctionner

Rouvrez la CLI et exécutez la commande suivante:

python mqttpub.py

Jetons un coup d'œil au canevas de l'abonné que nous avons créé et commencé plus tôt.

Le message que vous avez envoyé s'affiche.

finalement

Qu'as-tu pensé? J'ai pu facilement utiliser le Nifty Cloud MQTT.