mqttthreaddatalogger 1.6.0

Connexion mqtt et enregistrement des données dans un fichier csv

#mqttdatalogger

Enregistrement des données issues d'un serveur MQTT dans un fichier csv.

Exemple d'utilisation :

import getpass
import mqttthreaddatalogger as MQTT

Username = input('Entrez votre identifiant MQTT : ')
pwd = getpass.getpass('Entrez votre mot de passe MQTT :')

auth = {
'username':Username,
'password':pwd
}

crée le thread transport tcp ou websockets

m = MQTT.mqttthreaddatalogger("url_mqtt",portmqtt,auth["username"],auth["password"],"tcp")

topics auquel on s'abonne

m.selectTopic(["node_iot2020/arduino/out/"])

selection des clés des données voulues , les données seront dans m.data[0], m.data[1],...

m.selectKey(["['ecl']","['temps']"])

ou pour Lorawan, après le # se trouve le nom du champ qui sera utilisé dans le fichier csv,...

m.selectKey(["['uplink_message']['decoded_payload']['temperature']#temp","['uplink_message']['rx_metadata'][0]['gateway_ids']['gateway_id']#Id_gateway","['end_device_ids']['device_id']#ID_device"])
Après le # on rajoute le nom de la 1ère ligne du fichier de données
>

m.selectNomFichier("testdonnees.csv")

pour afficher ou non les info sur la console

m.affichage_console(True)

démarre le thread, (exécution indépendante du programme principal)

m.start()

time.sleep(1)
#publication d'un message vers MQTT
#m.client.publish("votretopic/test/in/",payload="{"pression":1024}",qos=0)