Compare commits

...

4 Commits

Author SHA1 Message Date
Jimmy b690a86215 Add Install tools. Add esp8266 firmware download 2021-05-29 15:00:36 +12:00
Jimmy 091d24a263 Renamed to main.py 2021-05-29 14:59:36 +12:00
Jimmy 71247d0154 Use mqtt robust, use config file 2021-05-29 14:59:03 +12:00
Jimmy 9ee2603137 Add config.json 2021-05-29 14:57:40 +12:00
4 changed files with 32 additions and 49 deletions

3
.gitignore vendored
View File

@ -1 +1,2 @@
data/ data/
config.json

View File

@ -1,3 +1,11 @@
# datalogger # Datalogger
ESP8266 running Micropython collecting temperature humidity and light level. Pushing data to a Mosquito server. A python script to ingest the data into an influx database. Grafana to display the data. ESP8266 running Micropython collecting temperature humidity and light level. Pushing data to a Mosquito server. A python script to ingest the data into an influx database. Grafana to display the data.
## Install tools
```pip3 install esptool adafruit-ampy```
## Download Esp8266 Firmware
https://micropython.org/resources/firmware/esp8266-20210418-v1.15.bin

View File

@ -2,26 +2,37 @@ from machine import Pin
from time import sleep from time import sleep
import machine import machine
import dht import dht
from umqtt.simple import MQTTClient from umqtt.robust import MQTTClient
import json import json
import gc import gc
with open("config.json", 'r') as f:
config = json.load(f)
print(config)
led = Pin(2, Pin.OUT) led = Pin(2, Pin.OUT)
d = dht.DHT11(Pin(16)) d = dht.DHT11(Pin(12))
adc = machine.ADC(0) adc = machine.ADC(0)
server="10.1.1.162"
c = MQTTClient("umqtt_client", server) c = MQTTClient("umqtt_client", config["mqtt"]["server"],ssl=True, user=config["mqtt"]["user"], password=config["mqtt"]["password"])
gc.enable() gc.enable()
while True: while True:
led(0) led(0)
d.measure() d.measure()
data = {'temp': d.temperature(), 'humid': d.humidity(),'light': adc.read(), 'id': 1} data = {'temp': d.temperature(), 'humid': d.humidity(),'light': adc.read(), 'id': config["id"]}
print(data) print(data)
led(1) led(1)
c.connect() try:
c.publish(b"sensors", json.dumps(data)) c.connect()
c.disconnect() c.publish(b"sensors", json.dumps(data))
finally:
c.disconnect()
gc.collect() gc.collect()
sleep(2)

View File

@ -1,37 +0,0 @@
from machine import Pin
from time import sleep
import machine
import dht
from umqtt.robust import MQTTClient
import json
import gc
with open("config.json", 'r') as f:
config = json.load(f)
print(config)
led = Pin(2, Pin.OUT)
d = dht.DHT11(Pin(12))
adc = machine.ADC(0)
c = MQTTClient("umqtt_client", config["mqtt"]["server"],ssl=True, user=config["mqtt"]["user"], password=config["mqtt"]["password"])
gc.enable()
while True:
led(0)
d.measure()
data = {'temp': d.temperature(), 'humid': d.humidity(),'light': adc.read(), 'id': config["id"]}
print(data)
led(1)
c.connect()
c.publish(b"sensors", json.dumps(data))
c.disconnect()
gc.collect()
# wdt.feed()
#sleep(1)