Das deutsche Python-Forum

Code: Alles auswählen

#include <DHT.h>
#define DHTPIN 2
#define DHTTYPE DHT22
DHT dht(DHTPIN, DHTTYPE);
int HUM;
int TEMP;


void setup() {
  Serial.begin(9600);
  dht.begin();
}
void loop() {
  getDHT22();
  Serial.println(TEMP);
  Serial.println(HUM);
}


void getDHT22() {
  HUM = dht.readHumidity();
  TEMP = dht.readTemperature();
}

Code: Alles auswählen

#!/usr/bin/env python3
import serial
import mysql.connector
import time

def store_to_database(t, h):
    mydb = mysql.connector.connect(
        host="localhost",
        user="user",
        password="passme",
        database="mydb"
    )

    mycursor = mydb.cursor()

    
    sql = "INSERT INTO mydb (Temp, LF, inserttime) VALUES (%s, %s, now())"
    val = (t, h,)
    mycursor.execute(sql, val)
    # Commit the changes to the database
    mydb.commit()

   
    mycursor.close()
    mydb.close()

if __name__ == '__main__':
    ser = serial.Serial('/dev/ttyACM0', 9600, timeout=1)

    while True:
        line = ser.readline().decode('utf-8').rstrip()
        t = line.split("\n")[0]
        line = ser.readline().decode('utf-8').rstrip()
        h = line.split("\n")[0]
        store_to_database(t,h)
        ser.reset_input_buffer()
        time.sleep(30)

Code: Alles auswählen

import serial
import mariadb
import sys
import time

# Konfiguration für die Serielle Schnittstelle
ser = serial.Serial('/dev/ttyACM0', 9600, timeout=1)

# Konfiguration für die Datenbankverbindung
config = {
  'host': 'localhost',
  'user': 'my_user',
  'password': 'my_pw',
  'database': 'mydb'
}

# Verbindung zur Datenbank herstellen
try:
    conn = mariadb.connect(**config)
except mariadb.Error as e:
    print(f"Fehler bei der Verbindung zur Datenbank: {e}")
    sys.exit(1)

# Cursor erstellen
cur = conn.cursor()

while True:
    try:
        # Arduino fragen, wie hoch die Werte momentan sind
        ser.write(b'r')
        arduino_data = ser.readline().decode('utf-8').strip().split('\t')
        temperature = float(arduino_data[0])
        humidity = float(arduino_data[1])

        # Daten in die Datenbank speichern
        cur.execute("INSERT INTO mydb (Temp, LF, inserttime) VALUES (?, ?, now())", (temperature, humidity))
        conn.commit()

        print(f"Temperatur: {temperature}°C, Luftfeuchtigkeit: {humidity}%")

    except (IndexError, ValueError, mariadb.Error) as e:
        print(f"Fehler beim Auslesen oder Speichern der Daten: {e}")
        time.sleep(1)
        continue

    time.sleep(10)

Code: Alles auswählen

#include "DHT.h"

#define DHTPIN 2
#define DHTTYPE DHT22
DHT dht(DHTPIN, DHTTYPE);

void setup() {
  Serial.begin(9600);
  dht.begin();
}

void loop() {
  if (Serial.available() > 0) {
    char c = Serial.read();
    if (c == 'r') {
      int h = dht.readHumidity();
      int t = dht.readTemperature();

      if (isnan(t) || isnan(h)) {
        Serial.println("Failed to read from DHT");
      } else {
        Serial.print(t);
        Serial.print('\t');
        Serial.println(h);
      }
    }
  }
}