Das deutsche Python-Forum

Code: Alles auswählen

# Benötigt: python3-serial

import serial
import urllib.request
import sys
import datetime

#sys.stdout = open('/dev/null', 'w')
#sys.stdout = open('/var/log/serialread.log', 'w')

ser = serial.Serial('/dev/ttyACM0', 9600)

while 1:
        time = datetime.datetime.now()
        rs232 = ser.readline().decode("ascii")
        print("Uhrzeit: ", time, end="\n")
        print("Empfangene Daten: ", rs232, end="\n")
        url = 'http://www.xxx.de/attiny/parse.php?r=1&key=xxxxx&' + rs232 #.decode("ascii")
        urlrequest = urllib.request.urlopen(url).read()
        urlrequest = urlrequest.decode("ascii")
        print("URL: ", url, end="\n")
        print("Ergebnis: ", urlrequest, end="\n")
        print("--------", end="\n")

Code: Alles auswählen

pi@raspi01 ~/serialread $ python3 serialread.py
Uhrzeit:  2013-12-28 20:51:16.024846
Empfangene Daten:  ss=3&t=1979&h=6830&v=4635

Traceback (most recent call last):
  File "serialread.py", line 21, in <module>
    urlrequest = urlrequest.decode("ascii")
UnicodeDecodeError: 'ascii' codec can't decode byte 0xe4 in position 226: ordinal not in range(128)

Code: Alles auswählen

Traceback (most recent call last):
  File "serialread.py", line 23, in <module>
    urlrequest = urllib.request.urlopen(url).read().decode("utf-8") # Web-Parse-Request absetzen und Statusausgabe in UTF-8 konvertieren
UnicodeDecodeError: 'utf-8' codec can't decode byte 0xe4 in position 226: invalid continuation byte

Code: Alles auswählen

pi@raspi01 ~/serialread $ python3 serialread-test.py
UnicodeDecodeError
rs232: s=s=3&t=1990&h=7150&v=4635

urlrequest: b'<br />\n<b>Warning</b>:  mysql_fetch_array() expects parameter 1 to be resource, boolean given in <b>/www/htdocs/w01081de/web/xxx/attiny/parse.php</b> on line <b>26</b><br />\nKeine SensorID gesetzt oder Sender nicht dem Empf\xe4nger zugeordnet'

Code: Alles auswählen

# Benoetigt: python3-serial

import serial
import urllib.request
#import sys
import datetime

ser = serial.Serial('/dev/ttyACM0', 9600) # Serielle Schnittstelle öffnen

while 1:
        time = datetime.datetime.now()
        rs232 = ser.readline().decode("utf-8") # Daten von COM abgreifen und in UTF8 formatieren

        if (rs232[0:2] == 's=') & (rs232[-8] == 'v'):
            log = open("serial.log", "a")
            logerror = open("serialerror.log", "a")

            print("Uhrzeit:          ", time, file=log)
            print("Empfangene Daten: ", rs232, end="", file=log)

            try:
                url = 'http://www.xxx/attiny/parse.php?r=1&key=xxxxxx&' + rs232 # Web-Parse-URL generieren
                urlrequesttemp = urllib.request.urlopen(url).read()
                urlrequest = urlrequesttemp.decode("utf-8") # Web-Parse-Request absetzen und Statusausgabe in UTF-8 konvertieren
#               print("URL: ", url, file=log)
                print("Ergebnis:         ", urlrequest, file=log)
                print("-", file=log)
            except UnicodeDecodeError:
                print("UnicodeDecodeError")
                print("rs232:", rs232)
                print("urlrequest:", urlrequesttemp)

            log.close()
        else:
             print("Daten nicht OK:", rs232)
             print("0:2", rs232[0:2])
             print("-6", rs232[-6])
             print("0:", rs232[0])
             print("len:", len(rs232))
             print("-1", rs232[-1])

Code: Alles auswählen

pi@raspi01 ~/serialread $ python3
Python 3.2.3 (default, Mar  1 2013, 11:53:50)
[GCC 4.6.3] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> url = b'<br />\n<b>Warning</b>:  mysql_fetch_array() expects parameter 1 to be resource, boolean given in <b>/www/htdocs/w01081de/web/xxx/attiny/parse.php</b> on line <b>26</b><br />\nKeine SensorID gesetzt oder Sender nicht dem Empf\xe4nger zugeordnet'
>>> url.decode("utf-8")
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
UnicodeDecodeError: 'utf-8' codec can't decode byte 0xe4 in position 226: invalid continuation byte
>>> url.decode("ascii")
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
UnicodeDecodeError: 'ascii' codec can't decode byte 0xe4 in position 226: ordinal not in range(128)
>>> url.decode("latin-1")
'<br />\n<b>Warning</b>:  mysql_fetch_array() expects parameter 1 to be resource, boolean given in <b>/www/htdocs/w01081de/web/xxx/attiny/parse.php</b> on line <b>26</b><br />\nKeine SensorID gesetzt oder Sender nicht dem Empfänger zugeordnet'

Code: Alles auswählen

<meta http-equiv="content-type" content="text/html; charset=UTF-8" />

Code: Alles auswählen

<br />
<b>Warning</b>:  mysql_fetch_array() expects parameter 1 to be resource, boolean given in <b>/www/htdocs/w01081de/web/xxx/attiny/parse.php</b> on line <b>26</b><br />
Keine SensorID gesetzt oder Sender nicht dem Empfänger zugeordnet

Code: Alles auswählen

# Benoetigt: python3-serial
# Im cron eintragen, damit es bei jedem Boot/Reboot gestartet wird:
# @reboot python3 /home/pi/serialread/serialread.py &

import serial
import urllib.request
import datetime

url = 'http://www.xxx/attiny/parse.php?r=1&key=xxx&'    # URL zum Webscript inkl. Secret und Receiver-ID

ser = serial.Serial('/dev/ttyACM0', 9600) # Serielle Schnittstelle öffnen

while 1:
        time = datetime.datetime.now()                  # Zeit für Log in eine Variable schreiben
        rs232raw = ser.readline().decode("utf-8")       # Daten von COM abgreifen und in UTF8 formatieren
        rs232 = rs232raw[0:len(rs232raw)-2]             # Die letzten beiden Zeichen abschneiden; es handelt sich um Leerzeichen

        log = open("serial.log", "a")                   # Log-Datei zum Anhängen öffnen

        if (rs232[2].isdigit()) & (rs232[4] == 't'):    # Wenn die 3. Stelle eine Zahl ist, und die 6. letzte ein "v"...

            print("-- Daten:         ", rs232, file=log)
            print("Uhrzeit:          ", time, file=log)
#            print("Empfangene Daten: ", rs232, end="", file=log)

            parseurl = url + rs232 # Web-Parse-URL generieren

            try:
                urlrequesttemp = urllib.request.urlopen(parseurl).read()        # Web-Parse-Request absetzen und Statusausgabe in UTF-8 konvertieren
                urlrequest = urlrequesttemp.decode("latin-1")                   # Parse-Antwort mit latin-1 dekodieren
                print("Ergebnis:         ", urlrequest.replace("<br>", " "), file=log) # Parse-Antwort ins Log schreiben, <br> durch Leerzeichen ersetzen
            except urllib.error.URLError:
                print("!! Exception:      ", end="", file=log)
                print("urllib.error.URLError: Host nicht gefunden, DNS-Fehler oder URL falsch?", file=log)

            print("-- / Daten\n", file=log)

        else:
             print("\n-- Daten nicht OK:", rs232, file=log)
             print("Pos 2 keine Zahl:", rs232[2], end="", file=log)
             print(" Pos 4 kein t:", rs232[-8], end="", file=log)
             print(" Länge:", len(rs232), file=log)
             print("-- / Daten\n", file=log)

        log.close()     # Log-File schließen

Code: Alles auswählen

with open(...) as f:
    # ``f`` ist in diesem Block als File-Objekt verfügbar

Code: Alles auswählen

from contextlib import closing
from datetime import datetime as DateTime
from serial import Serial
from urllib.parse import parse_qsl
import requests

# TODO Find better names.
URL = 'http://www.xxx/attiny/parse.php'
KEY = 'xxxxxx'


def parse_line(line):
    expected_keys = 'sthv'
    result = parse_qsl(line, keep_blank_values=True, strict_parsing=True)
    if len(result) != len(expected_keys):
        raise ValueError(
            'Wrong length, expected {} got {}'.format(
                len(expected_keys), len(result)
            )
        )
    for key, value in result:
        if key not in expected_keys:
            raise ValueError('Unexpected key {!r}'.format(key))
        try:
            int(value)
        except ValueError:
            raise ValueError(
                'Value for key {!r} is not a valid number: {!r}'.format(
                    key, value
                )
            )
    return result


def main():
    with closing(Serial('/dev/ttyACM0', 9600)) as serial:
        for line in serial:
            now = DateTime.now()
            try:
                parameters = parse_line(line.decode('ascii'))
            except (UnicodeDecodeError, ValueError) as error:
                print('Daten nicht OK:', ascii(line))
                print('Fehler:', error)
            else:
                with open('serial.log', 'a') as log_file:
                    print('Uhrzeit:          ', now, file=log_file)
                    print(
                        'Empfangene Daten: ',
                        ascii(line),
                        end='',
                        file=log_file
                    )
                    try:
                        parameters = [('r', '1'), ('key', KEY)] + parameters
                        response = requests.get(URL, params=parameters)
                        print(
                            'Ergebnis:         ', response.text, file=log_file
                        )
                        print('-', file=log_file)
                    except UnicodeDecodeError as error:
                        print(error)
                        print('line:', ascii(line))
                        print('url:', response.url)
                        print('response content:', ascii(response.content))


if __name__ == '__main__':
    main()

Code: Alles auswählen

# Benoetigt: python3-serial

# Im cron eintragen, damit es bei jedem Boot/Reboot gestartet wird:
# @reboot python3 /home/pi/serialread/serialread.py &
#
# Empfängt Daten über seriellen Port und übergibt sie an ein PHP-Webscript, dass diese in eine SQL-DB schreibt

# Die empfangenen Daten haben folgendes Format: s=3&t=2000&h=7160&v=4635

# Die komplette URL, die das PHP-WebScript aufruft, sieht wie folgt aus:
# http://www.xxx.de/parse.php?r=1&key=xxx&s=3&t=2000&h=7160&v=4635

# r = Receiver-ID (dieser Empfänger), key = Secret zum Auth am PHP-Script
# s = Sender-ID, t = Temperatur, h = Luftfeuchtigkeit, v = Spannung Stromversorgung

import serial
import urllib.request
from datetime import datetime as DateTime

RID = '1'                                               # ID des Receivers
URL = 'http://www.xxx/attiny/parse.php'
KEY = 'xxx'
LOGFILE = '/home/pi/serialread/serial.log'

serialcom = serial.Serial('/dev/ttyACM0', 9600)

serialdata_previous = ""

def format_received_data(rawdata):
    sdatatemp = rawdata.decode("utf-8")
    sdata = sdatatemp[0:len(sdatatemp)-2]
    return sdata

def check_received_data(received_data):
    if received_data[2].isdigit() and received_data[4] == 't':
        return True
    else:
        writelog("Daten haben falsches/fehlerhaftes Format: {0!r}".format(received_data))
        return False

def transfer_received_data(received_data, previous_received_data, RID, URL, KEY):
    if received_data == previous_received_data:
        return False

    urltoopen = "{0}?r={1}&key={2}{3}".format(URL, RID, KEY, received_data)

    try:
        transmit_result = urllib.request.urlopen(urltoopen).read().decode("latin-1").replace("<br>", " ")
        writelog("Daten wurden an WebScript übergeben: {0!r}, Status: {1!r}".format(received_data, transmit_result))
        return True
    except urllib.error.URLError:
        writelog("urllib.error.URLError: Host nicht gefunden, DNS-Fehler oder URL falsch?")
        return False

def writelog(text, logfilepath=LOGFILE, logfilemodi="a"):
    with open(logfilepath, logfilemodi) as log:
        current_time = DateTime.now().strftime("%d.%m.%Y %H:%M:%S")
        log.write("{0} {1}".format(current_time, text))


for line in serialcom:
        serialdata = format_received_data(line)

        if check_received_data(serialdata):
            transfer_received_data(serialdata, serialdata_previous, RID, URL, KEY)
            serialdata_previous = serialdata