Robin Cole
Published © Apache-2.0

Data Logging Zero to Hero with CircuitPython and MQTT

Using Python and open source software we publish data from a sensor over MQTT, persist the data and visualise it in real-time.

BeginnerFull instructions provided1 hour6,054
Data Logging Zero to Hero with CircuitPython and MQTT

Things used in this project

Story

Read more

Schematics

Wiring diagram

Wiring up the sensor

Code

code.py

MicroPython
The main file for part 2
import board
import busio
from digitalio import DigitalInOut
import time
import neopixel
from adafruit_esp32spi import adafruit_esp32spi
from adafruit_esp32spi import adafruit_esp32spi_wifimanager
import adafruit_esp32spi.adafruit_esp32spi_socket as socket
from adafruit_onewire.bus import OneWireBus
from adafruit_ds18x20 import DS18X20
from adafruit_minimqtt import MQTT
from secrets import secrets
from config import config

led = neopixel.NeoPixel(board.NEOPIXEL, 1)
led.brightness = 0.1

GREEN = (0, 255, 0)
RED = (255, 0, 0)

# Initialize one-wire bus on board pin D5.
ow_bus = OneWireBus(board.D5)
ds18 = DS18X20(ow_bus, ow_bus.scan()[0])

# If you are using a board with pre-defined ESP32 Pins:
esp32_cs = DigitalInOut(board.ESP_CS)
esp32_ready = DigitalInOut(board.ESP_BUSY)
esp32_reset = DigitalInOut(board.ESP_RESET)
spi = busio.SPI(board.SCK, board.MOSI, board.MISO)
esp = adafruit_esp32spi.ESP_SPIcontrol(spi, esp32_cs, esp32_ready, esp32_reset)
wifi = adafruit_esp32spi_wifimanager.ESPSPI_WiFiManager(esp, secrets)


def connect(client, userdata, flags, rc):
    print("Connected to MQTT Broker {}".format(secrets["mqtt-broker"]))
    print("Flags: {0}\n RC: {1}".format(flags, rc))


wifi.connect()
print("Connected to wifi with IP {}".format(wifi.ip_address()))

client = MQTT(socket, broker=secrets["mqtt-broker"], port=1883, network_manager=wifi)

# Connect callback handlers to client
client.on_connect = connect
client.connect()

while True:
    try:
        temperature = ds18.temperature
        print((ds18.temperature,))
        led[0] = GREEN
        client.publish(config["mqtt_topic"], temperature)
        time.sleep(0.1)
        led[0] = RED
        time.sleep(config["sleep_time"])
    except Exception as err:
        print("An error occured: {}".format(err))
        wifi.reset()
        wifi.connect()

secrets.py

Python
Example secrets file
# This file is where you keep secret settings, passwords, and tokens!
# If you put them in the code you risk committing that info or sharing it

secrets = {
    "ssid": "yours",
    "password": "yours",
    "timezone": "Europe/London",
    "mqtt-broker": "yours",
}

config.py

Python
The configuration for readings
# This file is where you keep secret settings, passwords, and tokens!
# If you put them in the code you risk committing that info or sharing it

config = {
    "mqtt_topic": "m4-temperature",
    "sleep_time": 1,
}

Credits

Robin Cole

Robin Cole

7 projects • 121 followers
Pythonista & PhD physics

Comments