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"])
m.selectNomFichier("testdonnees.csv")
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.3.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | fdf21c9687bc8fa3744fbeb1b208d7eec1bc2893355a373167a242f0ce0ad6da |
|
MD5 | dc62824e2259c2abf74f7a5aa925a183 |
|
BLAKE2b-256 | 88b88b490ffd29aab99fe1fb998053cc0bc1d8e41b881b671ebce580f6d07102 |
Hashes for mqttthreaddatalogger-1.3.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 841765c3cac41eacb5fb93edf587b69b80dcdc8a276d2792fc5651ba50e922ec |
|
MD5 | f2830a461e6e32f8ee0688bfdee242a3 |
|
BLAKE2b-256 | 6a236b85c08cd228e14fb1c24d3f5226a7aff408a5e08be216966a55a43f238a |