plantsiot.py

# --------- Libraries ------------
import time
from ISStreamer.Streamer import Streamer
from board import SCL, SDA
import busio
from adafruit_seesaw.seesaw import Seesaw
import mysql.connector
# --------------------------------

# --------- User Settings ---------
SENSOR_LOCATION_NAME = "House Plant"
BUCKET_NAME = "House Plant"
BUCKET_KEY = "soilsensor"
ACCESS_KEY = "ENTER KEY HERE"
MINUTES_BETWEEN_READS = 0.1
# ---------------------------------

# ------- Database enviroment ----
database_host="localhost"
database_name="plantsiotdb"
database_user="root"
# ---------------------------------

# -- InitialState + Sensor data --
i2c_bus = busio.I2C(SCL, SDA)
ss = Seesaw(i2c_bus, addr=0x36)
streamer = Streamer(bucket_name=BUCKET_NAME, bucket_key=BUCKET_KEY, access_key=ACCESS_KEY)

while True:
# Reads the moisture level through capacitive touch pad
    moisture = ss.moisture_read()
# Formats the input from 200-2000 range to % for readability
    moisture_p = format(moisture / 20)

# Reads the temperature from the temperature sensor 
    temp = ss.get_temp()
# Format the temperature to .2 decimals and a small calibration (-5)
    temp_c = format(temp - 5,".2f") 
    
# Prints out the moisture and temperature to terminal
    print("The moisture is: " + moisture_p + "%, " + "and the temperature is: " + temp_c + "C.")

# Sends the data to InitialState 
    streamer.log(SENSOR_LOCATION_NAME + " Moisture", moisture_p)
    streamer.log(SENSOR_LOCATION_NAME + " Temperature", temp_c)
    streamer.flush()
# ---------------------------------

# -- Database connection and queries --
# Sends the data to local MySQL database, the script is included. (plantsiotdb.sql)
# Prepared statement to send the data to the database and error handling.
    try:
        connection = mysql.connector.connect(host=database_host, database=database_name, user=database_user)
        cursor = connection.cursor(prepared=True)
        sql_insert_query = "INSERT INTO plantsiottable(plant_moisture, plant_temp) VALUES(%s,%s)"
        sql_touple = (moisture_p, temp_c)
        cursor.execute(sql_insert_query, sql_touple)
        connection.commit()

    except mysql.connector.Error as error:
        print("Error message {} ".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("Database received: " + str(sql_touple) +"\n")
    time.sleep(60*MINUTES_BETWEEN_READS)
# --------------------------------------