Connexion mqtt et enregistrement des données dans un fichier csv
Project description
#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']['analog_in_1']#température","['uplink_message']['rx_metadata'][0]['gateway_ids']['gateway_id']#gateway_id","['end_device_ids']['device_id']#device_id"])
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)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for mqttthreaddatalogger-1.5.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 9f5466bf1754df93ff4a79b0002b2a030dcc236ec9198811987bf854a079fdab |
|
MD5 | 760f63e4bba0e76e5b1f1f10f0ce98aa |
|
BLAKE2b-256 | 6cf6593d64c77a85e68620e5bde73e8684e142ec6ddab541299303fea14908e0 |
Hashes for mqttthreaddatalogger-1.5.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dccb7d98202a1a0939ef561bf117c61faf6e8e1e66045a6f6ffac8077e6e1d90 |
|
MD5 | 31358bc89c31f9821bedd23257b8b2a4 |
|
BLAKE2b-256 | a7fc5ae9644a8b5675dd89a8e5937e16e52627d331d84c40355e21c77af8eda0 |