Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/python
# coding=utf-8
# messprogramm.py
# ----------------
 
import os, sys, time

def aktuelleTemperatur():
      
    # 1-wire Slave Datei lesen
    file = open('/sys/bus/w1/devices/28-011317a451b8/w1_slave')
    filecontent = file.read()
    file.close()
 
    # Temperaturwerte auslesen und konvertieren
    stringvalue = filecontent.split("\n")[1].split(" ")[9]
    temperature = float(stringvalue[2:]) / 1000
 
    # Temperatur ausgeben
    rueckgabewert = '%6.2f' % temperature 
    return(rueckgabewert)
 
zeit = time.strftime('%H:%M:%S')
messdaten = aktuelleTemperatur()

try:
    while True:
        # Mit einem Timestamp versehe ich meine Messung und lasse mir diese in der Console ausgeben.
        print ("Temperatur um " + time.strftime('%H:%M:%S') +" beträgt:" + messdaten + " °C")
        # Nach 10 Sekunden erfolgt die nächste Messung
        time.sleep(10)
    
except KeyboardInterrupt:
    # Programm wird beendet wenn CTRL+C gedrückt wird.
    print('Temperaturmessung wird beendet')
except Exception as e:
    print(str(e))
    sys.exit(1)
finally:
    # Das Programm wird hier beendet, sodass kein Fehler in die Console geschrieben wird.
    print('Programm wird beendet.') 

Code: Alles auswählen

import os, sys, sqlite3
      
connection = sqlite3.connect("tempdata.db")
cursor = connection.cursor()


# Tabelle erzeugen
sql = """
CREATE TABLE IF NOT EXISTS tempWerte(
zeit TEXT(20),
temperatur FLOAT(20));"""
cursor.execute(sql)
    
connection.commit()
connection.close()

Code: Alles auswählen

import time, sys, sqlite3, Temperaturskript_22

def userTempWerte_db_anlegen():
    
    connection = sqlite3.connect("tempdata.db")
    cursor = connection.cursor()
   
    sql = """INSERT INTO tempWerte VALUES
            (%s,%s)""", (zeit,messdaten)
                               
    cursor.executemany(sql)
    
    connection.commit()
    connection.close()

Code: Alles auswählen

cusor.execute(sql, (zeit, messdaten))

Code: Alles auswählen

 def userTempWerte_db_anlegen(): 

Code: Alles auswählen

#!/usr/bin/python
# coding=utf-8
# messprogramm.py
#----------------
 
import os, sys, time, sqlite3
 
 
def aktuelleTemperatur():
      
    # 1-wire Slave Datei lesen
    file = open('/sys/bus/w1/devices/28-011317a451b8/w1_slave')
    filecontent = file.read()
    file.close()
 
    # Temperaturwerte auslesen und konvertieren
    stringvalue = filecontent.split("\n")[1].split(" ")[9]
    temperature = float(stringvalue[2:]) / 1000
 
    # Temperatur ausgeben
    rueckgabewert = '%6.2f' % temperature 
    return(rueckgabewert)
 
zeit = time.strftime('%H:%M:%S')
messdaten = aktuelleTemperatur()

while True :
    # Mit einem Timestamp versehe ich meine Messung und lasse mir diese in der Console ausgeben.
    print ("Temperatur um " + time.strftime('%H:%M:%S') +" beträgt:" + messdaten + " °C")
    
    # Verbindung zur DB herstellen
    verbindung = sqlite3.connect("temperatur.db")
    zeiger = verbindung.cursor()

    #Tabelle erzeugen falls nicht vorhanden   
    sql_anweisung = """
            CREATE TABLE IF NOT EXISTS temperaturwerte (
            zeit TEXT(30), 
            temperatur FLOAT(30));"""

    #Messdaten einfügen
    zeiger.execute(sql_anweisung)

   
    sql = "INSERT INTO temperaturwerte VALUES(?,?);"
                               
    zeiger.execute(sql, (zeit ,messdaten))
       
    verbindung.commit()
    zeiger.close()
                
    # Nach 5 Sekunden erfolgt die nächste Messung
    time.sleep(5)
             

Code: Alles auswählen

if __name__ == "__main__":
     main()

Code: Alles auswählen

temperature = float(stringvalue[2:]) / 1000

Code: Alles auswählen

    # Temperatur ausgeben
    rueckgabewert = '%6.2f' % temperature 
   

Code: Alles auswählen

#!/usr/bin/env python3
import sqlite3
import time
from contextlib import closing
from datetime import datetime as DateTime
from pathlib import Path


def read_temperature():
    return (
        float(
            Path("/sys/bus/w1/devices/28-011317a451b8/w1_slave")
            .read_text(encoding="ascii")
            .split("\n")[1]
            .split(" ")[9][2:]
        )
        / 1000
    )


def main():
    with sqlite3.connect("temperatur.db") as verbindung:
        with closing(verbindung.cursor()) as cursor:
            cursor.execute(
                """CREATE TABLE IF NOT EXISTS temperaturwerte (
                    zeit TIMESTAMP,
                    temperatur FLOAT
                )"""
            )
        
        while True:
            zeit = DateTime.now()
            temperature = read_temperature()
            
            print(
                f"Temperatur um {zeit:%H:%M:%S} beträgt {temperature:5.2.f} °C"
            )
            
            with closing(verbindung.cursor()) as cursor:
                cursor.execute(
                    "INSERT INTO temperaturwerte VALUES(?,?)",
                    (zeit, temperature),
                )
                verbindung.commit()

            time.sleep(5)


if __name__ == "__main__":
    main()

Code: Alles auswählen

with closing(verbindung.cursor()) as cursor:

Code: Alles auswählen

cursor = verbindung.cursor()