Das deutsche Python-Forum

Code: Alles auswählen

import sys
import os
import time
import calendar
import MySQLdb
import time
from time import *

lt = localtime()

file = open('/sys/devices/w1_bus_master1/w1_master_slaves')

w1_slave = file.readlines()

file.close()

for line in w1_slave:

 w1_slave = line.split("\n")[0]
 file = open('/sys/bus/w1/devices/' + str(w1_slave) + '/w1_slave')
 filecontent = file.read()
 file.close()
 stringvalue = filecontent.split("\n")[1].split(" ")[9]
 temperatur_sensor = float(stringvalue[2:]) / 1000


 connection = MySQLdb.connect (host="server", user="user", passwd="psw", db="rasp_temp")

 cursor = connection.cursor()
 cursor.execute("""CREATE TABLE IF NOT EXISTS temperatur (temperatur FLOAT(5))""")
 cursor.execute("""'INSERT INTO temperatur VALUES ('%s')"""),(temperatur_sensor1)
 connection.commit()
 cursor.close();

sys.exit(0)
   

Code: Alles auswählen

root@raspberrypi:/home/pi/Proggis# python Rasp_temp_mysql.py 
Traceback (most recent call last):
  File "Rasp_temp_mysql.py", line 31, in <module>
    cursor.execute("""'INSERT INTO temperatur VALUES ('%s')"""),(temperatur_sensor1)
  File "/usr/lib/python2.7/dist-packages/MySQLdb/cursors.py", line 174, in execute
    self.errorhandler(self, exc, value)
  File "/usr/lib/python2.7/dist-packages/MySQLdb/connections.py", line 36, in defaulterrorhandler
    raise errorclass, errorvalue
_mysql_exceptions.ProgrammingError: (1064, "You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ''INSERT INTO temperatur VALUES ('%s')' at line 1")

Code: Alles auswählen

#!/usr/bin/env python
from itertools import imap
import MySQLdb


def read_sensor_value(name):
    with open('/sys/bus/w1/devices/{0}/w1_slave'.format(name)) as sensor_file:
        next(sensor_file)  # Skip first line.
        return float(next(sensor_file).split(' ')[9][2:]) / 1000


def iter_sensor_names():
    with open('/sys/devices/w1_bus_master1/w1_master_slaves') as lines:
        return (line.rstrip() for line in lines)


def main():
    connection = MySQLdb.connect(
        host='server', user='user', passwd='psw', db='rasp_temp'
    )
    cursor = connection.cursor()
    cursor.execute(
        'CREATE TABLE IF NOT EXISTS temperatur (temperatur FLOAT(5))'
    )
    cursor.executemany(
        'INSERT INTO temperatur VALUES (%s)',
        ((value,) for value in imap(read_sensor_value, iter_sensor_names))
    )
    connection.commit()
    cursor.close()


if __name__ == '__main__':
    main()

Code: Alles auswählen

#!/usr/bin/python
# -*- coding: utf-8 -*-

import MySQLdb as mdb # eingefügt
import os
import glob
import time

os.system('modprobe w1-gpio') 
os.system('modprobe w1-therm')

base_dir = '/sys/bus/w1/devices/' 
device_folder = glob.glob(base_dir + '28*')[0]
device_file = device_folder + '/w1_slave'

def read_temp_raw():
    f = open(device_file, 'r')
    lines = f.readlines()
    f.close()
    return lines

def read_temp():
    lines = read_temp_raw()
    while lines[0].strip()[-3:] != 'YES':
        time.sleep(0.2)
        lines = read_temp_raw()
    equals_pos = lines[1].find('t=')
    if equals_pos != -1:
        temp_string = lines[1][equals_pos+2:]
        temp_c = float(temp_string) / 1000.0
        #temp_f = temp_c * 9.0 / 5.0 + 32.0
        return temp_c, # temp_f
	
while True:
        con = mdb.connect('localhost', 'xxx', 'xxx', 'temp');

        with con:

            cur = con.cursor()
            cur.execute("INSERT INTO templog(temp) VALUES(read_temp())")
	# print(read_temp())
	time.sleep(60)

Code: Alles auswählen

print("read_temp()")

Code: Alles auswählen

cur.execute("INSERT INTO templog(temp) VALUES(%s)", read_temp())