Compare commits
22 Commits
Author | SHA1 | Date | |
---|---|---|---|
9e78b44184 | |||
7f41480cc8 | |||
67c7d20b1b | |||
3598abe51f | |||
a2369f3863 | |||
03beec6a85 | |||
3434ab2d9f | |||
995f9ff194 | |||
c76aa08c83 | |||
63210ee88d | |||
c8b9518c11 | |||
9f4428cdbc | |||
acc0f965ff | |||
c8ea31042e | |||
601b5de46d | |||
3871bb8d99 | |||
![]() |
0982608da1 | ||
![]() |
b580f7fd5b | ||
f7a5db9f39 | |||
298151634d | |||
fc8b033215 | |||
535087c248 |
@@ -14,4 +14,12 @@ CC-BY-SA Olli Graf
|
|||||||
| 7 | Module|
|
| 7 | Module|
|
||||||
| 8 | Exceptions|
|
| 8 | Exceptions|
|
||||||
| 9 | Typkonvertierung|
|
| 9 | Typkonvertierung|
|
||||||
|
|10 | Dateien|
|
||||||
|
|11 | Datum und Zeit|
|
||||||
|
|12 | Multithreading|
|
||||||
|
|13 | Netzwerk|
|
||||||
|
|14 | Logging|
|
||||||
|
|15 | GPIO|
|
||||||
|
|16 | Testing|
|
||||||
|
|17 | Datenbank|
|
||||||
|
|
||||||
|
BIN
teil10/__pycache__/namen.cpython-39.pyc
Normal file
BIN
teil10/__pycache__/namen.cpython-39.pyc
Normal file
Binary file not shown.
5
teil10/namen.csv
Normal file
5
teil10/namen.csv
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
Skinner,Seymour
|
||||||
|
Largo,Dewey
|
||||||
|
Krabappel,Edna
|
||||||
|
Hoover,Elisabeth
|
||||||
|
Chalmers,Gary
|
|
1
teil10/namen.py
Normal file
1
teil10/namen.py
Normal file
@@ -0,0 +1 @@
|
|||||||
|
namen = ["Homer", "Marge", "Bart"]
|
3
teil10/namen.txt
Normal file
3
teil10/namen.txt
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
Homer
|
||||||
|
Marge
|
||||||
|
Bart
|
29
teil10/read_csv.py
Normal file
29
teil10/read_csv.py
Normal file
@@ -0,0 +1,29 @@
|
|||||||
|
school = []
|
||||||
|
class Lehrer():
|
||||||
|
|
||||||
|
def __init__(self, vorname, name):
|
||||||
|
self.vorname = vorname
|
||||||
|
self.name = name
|
||||||
|
|
||||||
|
def __str__(self):
|
||||||
|
return f'{self.vorname} {self.name}'
|
||||||
|
|
||||||
|
|
||||||
|
try:
|
||||||
|
|
||||||
|
with open('namen.csv','r') as f:
|
||||||
|
for line in f:
|
||||||
|
splitted = line.strip().split(',')
|
||||||
|
name = splitted[0]
|
||||||
|
vorname = splitted[1]
|
||||||
|
|
||||||
|
lehrer = Lehrer(vorname,name)
|
||||||
|
school.append(lehrer)
|
||||||
|
|
||||||
|
|
||||||
|
except IOError as x:
|
||||||
|
print(f'I/O-Fehler: {x}')
|
||||||
|
|
||||||
|
print(school)
|
||||||
|
print(school[0])
|
||||||
|
print(school[3])
|
17
teil10/read_file.py
Normal file
17
teil10/read_file.py
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
namen = []
|
||||||
|
|
||||||
|
try:
|
||||||
|
f = open('namen.txt','r')
|
||||||
|
#f = open('namen.txt','r',encoding='utf-8')
|
||||||
|
|
||||||
|
for line in f:
|
||||||
|
namen.append(line)
|
||||||
|
# namen.append(line.strip())
|
||||||
|
except IOError as x:
|
||||||
|
print(f'I/O-Fehler: {x}')
|
||||||
|
finally:
|
||||||
|
if f != None:
|
||||||
|
f.close()
|
||||||
|
|
||||||
|
|
||||||
|
print(namen)
|
15
teil10/write_file.py
Normal file
15
teil10/write_file.py
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
from namen import namen
|
||||||
|
|
||||||
|
f = open('namen.txt','w')
|
||||||
|
|
||||||
|
try:
|
||||||
|
for name in namen:
|
||||||
|
f.write(f'{name}\n')
|
||||||
|
except IOError as err:
|
||||||
|
print(f'I/O-Fehler {err}')
|
||||||
|
finally:
|
||||||
|
if f != None:
|
||||||
|
f.close()
|
||||||
|
|
||||||
|
|
||||||
|
|
12
teil10/write_file_with.py
Normal file
12
teil10/write_file_with.py
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
from namen import namen
|
||||||
|
|
||||||
|
|
||||||
|
try:
|
||||||
|
with open('namen.txt','w') as f:
|
||||||
|
for name in namen:
|
||||||
|
f.write(f'{name}\n')
|
||||||
|
except IOError as err:
|
||||||
|
print(f'I/O-Fehler {err}')
|
||||||
|
|
||||||
|
|
||||||
|
|
10
teil11/create_datetime.py
Normal file
10
teil11/create_datetime.py
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
datum = datetime.strptime('12.12.2002', '%d.%m.%Y')
|
||||||
|
|
||||||
|
print(f'Jahr: {datum.year}')
|
||||||
|
print(f'Monat: {datum.month}')
|
||||||
|
print(f'Tag: {datum.day}')
|
||||||
|
|
||||||
|
print(datum)
|
||||||
|
|
9
teil11/currentdate.py
Normal file
9
teil11/currentdate.py
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
heute = datetime.now()
|
||||||
|
|
||||||
|
print(type(heute))
|
||||||
|
print(heute)
|
||||||
|
print(heute.time())
|
||||||
|
print(heute.date())
|
||||||
|
|
10
teil11/formatted_date.py
Normal file
10
teil11/formatted_date.py
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
heute = datetime.now()
|
||||||
|
|
||||||
|
print(type(heute))
|
||||||
|
print(heute.strftime('%c %X'))
|
||||||
|
print(heute.time().strftime('%X'))
|
||||||
|
print(heute.date().strftime('%x'))
|
||||||
|
print(heute.strftime('%d.%m.%y %H:%M'))
|
||||||
|
|
34
teil11/zeitmessung.py
Normal file
34
teil11/zeitmessung.py
Normal file
@@ -0,0 +1,34 @@
|
|||||||
|
from timeit import default_timer as timer
|
||||||
|
import time
|
||||||
|
|
||||||
|
def calc_square(numbers, verbose=False):
|
||||||
|
for n in range(1,numbers):
|
||||||
|
q= n*n
|
||||||
|
if verbose:
|
||||||
|
print(f'\n{n} ^ 2 = {q}')
|
||||||
|
time.sleep(0.1)
|
||||||
|
|
||||||
|
def calc_cube(numbers,verbose=False):
|
||||||
|
for n in range(1,numbers):
|
||||||
|
k = n*n*n
|
||||||
|
if verbose:
|
||||||
|
print(f'\n{n} ^ 3 = {k}')
|
||||||
|
time.sleep(0.1)
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
|
||||||
|
calc_square(100,True)
|
||||||
|
calc_cube(100,True)
|
||||||
|
|
||||||
|
ende = timer()
|
||||||
|
differenz = ende - start
|
||||||
|
print(f'Zeit mit print():{differenz}s')
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
|
||||||
|
calc_square(100)
|
||||||
|
calc_cube(100)
|
||||||
|
|
||||||
|
ende = timer()
|
||||||
|
differenz = ende - start
|
||||||
|
print(f'Zeit ohne print():{differenz}s')
|
4004
teil12/multi_write.log
Normal file
4004
teil12/multi_write.log
Normal file
File diff suppressed because it is too large
Load Diff
32
teil12/multi_write.py
Normal file
32
teil12/multi_write.py
Normal file
@@ -0,0 +1,32 @@
|
|||||||
|
import threading
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logging.basicConfig(
|
||||||
|
format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s',
|
||||||
|
filename='multi_write.log',
|
||||||
|
level=logging.DEBUG)
|
||||||
|
|
||||||
|
datei = open('zahlen.txt','w')
|
||||||
|
|
||||||
|
def write_number(zahl):
|
||||||
|
|
||||||
|
for i in range(0,1000):
|
||||||
|
logging.debug(f'Thread {zahl}/schreibe {i}')
|
||||||
|
datei.write(f'{i}:{zahl}\n')
|
||||||
|
datei.flush()
|
||||||
|
|
||||||
|
thread_1 = threading.Thread(target=write_number,args=(1,))
|
||||||
|
thread_2 = threading.Thread(target=write_number,args=(2,))
|
||||||
|
|
||||||
|
logging.debug('starte Thread 1')
|
||||||
|
thread_1.start()
|
||||||
|
logging.debug('starte Thread 2')
|
||||||
|
thread_2.start()
|
||||||
|
|
||||||
|
|
||||||
|
thread_1.join()
|
||||||
|
thread_2.join()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
46
teil12/multithreading.py
Normal file
46
teil12/multithreading.py
Normal file
@@ -0,0 +1,46 @@
|
|||||||
|
from timeit import default_timer as timer
|
||||||
|
import time
|
||||||
|
import threading
|
||||||
|
|
||||||
|
def calc_square(numbers, verbose=False):
|
||||||
|
for n in range(1,numbers):
|
||||||
|
q= n*n
|
||||||
|
if verbose:
|
||||||
|
print(f'\n{n} ^ 2 = {q}')
|
||||||
|
time.sleep(0.1)
|
||||||
|
|
||||||
|
def calc_cube(numbers,verbose=False):
|
||||||
|
for n in range(1,numbers):
|
||||||
|
k = n*n*n
|
||||||
|
if verbose:
|
||||||
|
print(f'\n{n} ^ 3 = {k}')
|
||||||
|
time.sleep(0.1)
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
|
||||||
|
thread_square = threading.Thread(target=calc_square, args=(100,True))
|
||||||
|
thread_cube = threading.Thread(target=calc_cube, args=(100,True))
|
||||||
|
|
||||||
|
thread_cube.start()
|
||||||
|
thread_square.start()
|
||||||
|
|
||||||
|
thread_cube.join()
|
||||||
|
thread_square.join()
|
||||||
|
ende = timer()
|
||||||
|
differenz_mit_print = ende - start
|
||||||
|
print(f'Zeit mit print():{differenz_mit_print}s')
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
|
||||||
|
thread_square = threading.Thread(target=calc_square, args=(100,False))
|
||||||
|
thread_cube = threading.Thread(target=calc_cube, args=(100,False))
|
||||||
|
|
||||||
|
thread_cube.start()
|
||||||
|
thread_square.start()
|
||||||
|
|
||||||
|
thread_cube.join()
|
||||||
|
thread_square.join()
|
||||||
|
|
||||||
|
ende = timer()
|
||||||
|
differenz_ohne_print = ende - start
|
||||||
|
print(f'Zeit ohne print():{differenz_ohne_print}s')
|
52
teil12/pool.py
Normal file
52
teil12/pool.py
Normal file
@@ -0,0 +1,52 @@
|
|||||||
|
# encoding: UTF-8
|
||||||
|
from timeit import default_timer as timer
|
||||||
|
import datetime
|
||||||
|
import multiprocessing
|
||||||
|
import time
|
||||||
|
import random
|
||||||
|
|
||||||
|
from multiprocessing import Pool
|
||||||
|
|
||||||
|
def func1(*args, **kwargs):
|
||||||
|
sleep_time = random.randint(3, 6)
|
||||||
|
print(f'Prozess : {multiprocessing.current_process().name}\tFunktion : func1\tArgs:{args}\tgeschlafen {sleep_time} \tZeit : {datetime.datetime.now()}\n')
|
||||||
|
print("Keyword Args from func1: %s" % kwargs)
|
||||||
|
time.sleep(sleep_time)
|
||||||
|
print(f'{multiprocessing.current_process().name}\t func1 fertig: {datetime.datetime.now()}\n')
|
||||||
|
return sum(*args)
|
||||||
|
|
||||||
|
def func2(*args):
|
||||||
|
sleep_time = random.randint(7, 10)
|
||||||
|
print(f'Prozess : {multiprocessing.current_process().name}\tFunktion : func2\tArgs:{args}\tgeschlafen {sleep_time} \tZeit : {datetime.datetime.now()}\n')
|
||||||
|
time.sleep(sleep_time)
|
||||||
|
print(f'{multiprocessing.current_process().name}\t func2 fertig: {datetime.datetime.now()}\n')
|
||||||
|
return sum(*args)
|
||||||
|
|
||||||
|
def func3(*args):
|
||||||
|
sleep_time = random.randint(0, 3)
|
||||||
|
print(f'Prozess : {multiprocessing.current_process().name}\tFunktion : func3\ttArgs:{args}\tgeschlafen {sleep_time} \tZeit : {datetime.datetime.now()}\n')
|
||||||
|
time.sleep(sleep_time)
|
||||||
|
print(f'{multiprocessing.current_process().name}\t func3 fertig: {datetime.datetime.now()}\n')
|
||||||
|
return sum(*args)
|
||||||
|
|
||||||
|
def smap(f, *arg):
|
||||||
|
if len(arg) == 2:
|
||||||
|
args, kwargs = arg
|
||||||
|
return f(list(args), **kwargs)
|
||||||
|
elif len(arg) == 1:
|
||||||
|
args = arg
|
||||||
|
return f(*args)
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
with Pool(processes=3) as pool:
|
||||||
|
result = pool.starmap(smap, [(func1, [1,2,3],{'a':123, 'b':456}), (func2, [11,22,33]), (func3, [111,222,333])])
|
||||||
|
print(f'Ergebnis: {result}')
|
||||||
|
|
||||||
|
ende = timer()
|
||||||
|
diff = ende - start
|
||||||
|
print(f'Ausführzeit: {diff}s')
|
||||||
|
|
||||||
|
|
12
teil12/pool2.py
Normal file
12
teil12/pool2.py
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
# Quelle: https://stackoverflow.com/questions/35528093/multithreading-in-python-with-a-threadpool
|
||||||
|
from multiprocessing import Pool
|
||||||
|
import sys
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
|
||||||
|
job_list = [range(10000000)]*6
|
||||||
|
|
||||||
|
print(f'{job_list}')
|
||||||
|
p = Pool(2)
|
||||||
|
print("Parallel map")
|
||||||
|
print(p.map(sum, job_list))
|
20
teil12/pool3.py
Normal file
20
teil12/pool3.py
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
# Quelle: https://www.codesdope.com/blog/article/multiprocessing-using-pool-in-python/
|
||||||
|
import time
|
||||||
|
from multiprocessing import Pool
|
||||||
|
|
||||||
|
|
||||||
|
def square(x):
|
||||||
|
print(f"start process:{x}")
|
||||||
|
square = x * x
|
||||||
|
print(f"square {x}:{square}")
|
||||||
|
time.sleep(1)
|
||||||
|
print(f"end process:{x}")
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
starttime = time.time()
|
||||||
|
pool = Pool()
|
||||||
|
pool.map(square, range(0, 5))
|
||||||
|
pool.close()
|
||||||
|
endtime = time.time()
|
||||||
|
print(f"Time taken {endtime-starttime} seconds")
|
80
teil12/pool_squares.py
Normal file
80
teil12/pool_squares.py
Normal file
@@ -0,0 +1,80 @@
|
|||||||
|
#encoding: UTF-8
|
||||||
|
|
||||||
|
import datetime
|
||||||
|
from timeit import default_timer as timer
|
||||||
|
import multiprocessing
|
||||||
|
import time
|
||||||
|
import random
|
||||||
|
from multiprocessing import Pool
|
||||||
|
|
||||||
|
__verbose__ = False
|
||||||
|
|
||||||
|
# gibt den String s nur aus, wenn __verbose__ True ist.
|
||||||
|
def print_verbose(s):
|
||||||
|
if __verbose__:
|
||||||
|
print(s)
|
||||||
|
|
||||||
|
# Arbeitsfunktion läuft in der Zahlenliste von start bis ende
|
||||||
|
# und summiert die Quadratzahlen in dem Bereich auf.
|
||||||
|
# Die Methode wird in jedem Prozess mit unterschiedlichen Werten
|
||||||
|
# für start und ende abgearbeitet.
|
||||||
|
def calc_sum_square(zahlen, *args,**kwargs):
|
||||||
|
print(f'calc_sum_square() {args}')
|
||||||
|
time.sleep(1.0)
|
||||||
|
start = kwargs['start']
|
||||||
|
ende = kwargs['end']
|
||||||
|
threadnr = kwargs['threadnr']
|
||||||
|
summe = 0
|
||||||
|
|
||||||
|
print_verbose(f'von {start} bis {ende}')
|
||||||
|
for n in range(start,ende):
|
||||||
|
i = zahlen[n]
|
||||||
|
print_verbose(f'Berechnung:{threadnr}: {i}, {i*i}')
|
||||||
|
summe = summe + i*i
|
||||||
|
|
||||||
|
return summe
|
||||||
|
|
||||||
|
# Diese Methode wird initial pro Prozess von der Poolsteuerung aufgerufen und
|
||||||
|
# steuert die Verteilung der Parameter.
|
||||||
|
# f ist der Zeiger auf die aufzurufende Methode
|
||||||
|
# *arg wnthält das Tupel mit den Argumenten
|
||||||
|
#
|
||||||
|
def smap(f, *arg):
|
||||||
|
|
||||||
|
# Auflösen des Tupels: args enthält die Liste mit den Zahlen,
|
||||||
|
# kwarg das Dictionary mit den Parametern für jeden Prozess
|
||||||
|
args, kwargs = arg
|
||||||
|
|
||||||
|
# Aufruf der übergebenen Funktion mit den Parametern
|
||||||
|
return f(args, **kwargs)
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
# Liste mit 10 Mio Integerzahlen anlegen.
|
||||||
|
zahlen = [i for i in range(10000000)]
|
||||||
|
ende = timer()
|
||||||
|
print(f'Zahlenliste erzeugt in {ende-start}s')
|
||||||
|
|
||||||
|
split = int(len(zahlen) / 3)
|
||||||
|
print_verbose(f'split={split}')
|
||||||
|
time.sleep(1.0)
|
||||||
|
|
||||||
|
start = timer()
|
||||||
|
# Pool mit drei Prozesssen
|
||||||
|
with Pool(processes=3) as pool:
|
||||||
|
# Die Methode pool.starmap() bekommt neben der aufzurufenden Methode smap() eine Liste von Tupeln.
|
||||||
|
# Jedes Tupel enthält pro Prozess die auszuführende Methode, die Liste mit den Zahlen und ein Dictionary mit
|
||||||
|
# den Parametern 'threadnr', 'start' und 'end'
|
||||||
|
# starmap() wartet solange, bis alle drei Teilprozesse beendet sind und gibt dann eine Liste mit den return Werten
|
||||||
|
# zurück.
|
||||||
|
result = pool.starmap(smap, [(calc_sum_square, zahlen, {'threadnr':1,'start':0, 'end':split}), (calc_sum_square, zahlen, {'threadnr':2,'start':split+1,'end':split*2}), (calc_sum_square, zahlen,{'threadnr':3,'start':(split*2)+1,'end':split*3})])
|
||||||
|
print(f'Ergebnis: {result}')
|
||||||
|
ende = timer()
|
||||||
|
print(f'Ausführzeit: {ende-start}s')
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
14
teil12/pools.py
Normal file
14
teil12/pools.py
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
from multiprocessing import Pool
|
||||||
|
import time
|
||||||
|
|
||||||
|
def calculate_square(n):
|
||||||
|
return n*n
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
starttime = time.time()
|
||||||
|
pool = Pool()
|
||||||
|
pool.map(calculate_square, range(0, 5))
|
||||||
|
pool.close()
|
||||||
|
endtime = time.time()
|
||||||
|
print(f"Time taken {endtime-starttime} seconds")
|
||||||
|
|
37
teil12/race_condition.py
Normal file
37
teil12/race_condition.py
Normal file
@@ -0,0 +1,37 @@
|
|||||||
|
import threading
|
||||||
|
import time
|
||||||
|
import random
|
||||||
|
|
||||||
|
gesamtwert = 0
|
||||||
|
message = ''
|
||||||
|
|
||||||
|
def calculate_sum(thread_nummer):
|
||||||
|
global gesamtwert
|
||||||
|
global message
|
||||||
|
|
||||||
|
for i in range(100 + thread_nummer):
|
||||||
|
zwischen = gesamtwert
|
||||||
|
#Zufällige Wartezeit zwischen 0,1s und 0,5s
|
||||||
|
wartezeit = random.randint(1,5+thread_nummer)
|
||||||
|
time.sleep(0.1 * wartezeit)
|
||||||
|
|
||||||
|
zwischen += 1
|
||||||
|
gesamtwert = zwischen
|
||||||
|
message = f'Thread {thread_nummer} fertig'
|
||||||
|
print(f'Thread + {thread_nummer} abgearbeitet.')
|
||||||
|
|
||||||
|
# zwei Threads starten, um die Summe der Zahlen zu berechnen
|
||||||
|
gesamtwert = 0
|
||||||
|
t1 = threading.Thread(target=calculate_sum, args=(1,))
|
||||||
|
t2 = threading.Thread(target=calculate_sum, args=(2,))
|
||||||
|
t3 = threading.Thread(target=calculate_sum, args=(3,))
|
||||||
|
t1.start()
|
||||||
|
t2.start()
|
||||||
|
t3.start()
|
||||||
|
t1.join()
|
||||||
|
t3.join()
|
||||||
|
t2.join()
|
||||||
|
|
||||||
|
|
||||||
|
print(f'gesamtwert={gesamtwert}')
|
||||||
|
print(f'message={message}')
|
44
teil12/race_condition_asyncio.py
Normal file
44
teil12/race_condition_asyncio.py
Normal file
@@ -0,0 +1,44 @@
|
|||||||
|
import asyncio
|
||||||
|
import random
|
||||||
|
import time
|
||||||
|
|
||||||
|
gesamtwert = 0
|
||||||
|
message = ''
|
||||||
|
|
||||||
|
|
||||||
|
async def calculate_sum(lock, thread_nummer):
|
||||||
|
global gesamtwert
|
||||||
|
global message
|
||||||
|
|
||||||
|
for i in range(100 + thread_nummer):
|
||||||
|
async with lock:
|
||||||
|
zwischen = gesamtwert
|
||||||
|
#Zufällige Wartezeit zwischen 0,1s und 0,5s
|
||||||
|
wartezeit = random.randint(1,5+thread_nummer)
|
||||||
|
time.sleep(0.1 * wartezeit)
|
||||||
|
|
||||||
|
zwischen += 1
|
||||||
|
|
||||||
|
async with lock:
|
||||||
|
gesamtwert = zwischen
|
||||||
|
|
||||||
|
message = f'Thread {thread_nummer} fertig'
|
||||||
|
print(f'Thread + {thread_nummer} abgearbeitet.')
|
||||||
|
|
||||||
|
async def main():
|
||||||
|
|
||||||
|
#async Lock erzeugen
|
||||||
|
lock = asyncio.Lock()
|
||||||
|
|
||||||
|
# drei Threads starten, um die Summe der Zahlen zu berechnen
|
||||||
|
|
||||||
|
threads = [asyncio.create_task(calculate_sum(lock, _+1)) for _ in range(3)]
|
||||||
|
|
||||||
|
#Warten auf alle Threads
|
||||||
|
await asyncio.gather(*threads)
|
||||||
|
|
||||||
|
print(f'gesamtwert={gesamtwert}')
|
||||||
|
print(f'message={message}')
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
asyncio.run(main())
|
43
teil12/race_condition_lock.py
Normal file
43
teil12/race_condition_lock.py
Normal file
@@ -0,0 +1,43 @@
|
|||||||
|
import threading
|
||||||
|
import time
|
||||||
|
import random
|
||||||
|
|
||||||
|
gesamtwert = 0
|
||||||
|
message = ''
|
||||||
|
lock = threading.Lock()
|
||||||
|
|
||||||
|
|
||||||
|
def calculate_sum(thread_nummer,lock):
|
||||||
|
global gesamtwert
|
||||||
|
global message
|
||||||
|
|
||||||
|
for i in range(100 + thread_nummer):
|
||||||
|
with lock:
|
||||||
|
zwischen = gesamtwert
|
||||||
|
#Zufällige Wartezeit zwischen 0,1s und 0,5s
|
||||||
|
wartezeit = random.randint(1,5+thread_nummer)
|
||||||
|
time.sleep(0.1 * wartezeit)
|
||||||
|
|
||||||
|
zwischen += 1
|
||||||
|
|
||||||
|
with lock:
|
||||||
|
gesamtwert = zwischen
|
||||||
|
|
||||||
|
message = f'Thread {thread_nummer} fertig'
|
||||||
|
print(f'Thread + {thread_nummer} abgearbeitet.')
|
||||||
|
|
||||||
|
# zwei Threads starten, um die Summe der Zahlen zu berechnen
|
||||||
|
gesamtwert = 0
|
||||||
|
t1 = threading.Thread(target=calculate_sum, args=(1,lock,))
|
||||||
|
t2 = threading.Thread(target=calculate_sum, args=(2,lock,))
|
||||||
|
t3 = threading.Thread(target=calculate_sum, args=(3,lock,))
|
||||||
|
t1.start()
|
||||||
|
t2.start()
|
||||||
|
t3.start()
|
||||||
|
t1.join()
|
||||||
|
t3.join()
|
||||||
|
t2.join()
|
||||||
|
|
||||||
|
|
||||||
|
print(f'gesamtwert={gesamtwert}')
|
||||||
|
print(f'message={message}')
|
37
teil12/threadpools.py
Normal file
37
teil12/threadpools.py
Normal file
@@ -0,0 +1,37 @@
|
|||||||
|
import concurrent.futures
|
||||||
|
import random
|
||||||
|
import time
|
||||||
|
|
||||||
|
gesamtwert = 0
|
||||||
|
message = ''
|
||||||
|
|
||||||
|
|
||||||
|
def calculate_sum(thread_nummer):
|
||||||
|
global gesamtwert
|
||||||
|
global message
|
||||||
|
|
||||||
|
for i in range(100 + thread_nummer):
|
||||||
|
zwischen = gesamtwert
|
||||||
|
#Zufällige Wartezeit zwischen 0,1s und 0,5s
|
||||||
|
wartezeit = random.randint(1,5+thread_nummer)
|
||||||
|
time.sleep(0.1 * wartezeit)
|
||||||
|
|
||||||
|
zwischen += 1
|
||||||
|
|
||||||
|
gesamtwert = zwischen
|
||||||
|
|
||||||
|
message = f'Thread {thread_nummer} fertig'
|
||||||
|
print(f'Thread + {thread_nummer} abgearbeitet.')
|
||||||
|
|
||||||
|
def main():
|
||||||
|
|
||||||
|
with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
|
||||||
|
threads = [executor.submit(calculate_sum, i+1) for i in range(3)]
|
||||||
|
|
||||||
|
results = [t.result() for t in threads]
|
||||||
|
|
||||||
|
print(f'gesamtwert={gesamtwert}')
|
||||||
|
print(f'message={message}')
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
main()
|
2
teil13/.gitignore
vendored
Normal file
2
teil13/.gitignore
vendored
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
./__pycache__
|
||||||
|
./network/__pycache__/*
|
BIN
teil13/__pycache__/network.cpython-39.pyc
Normal file
BIN
teil13/__pycache__/network.cpython-39.pyc
Normal file
Binary file not shown.
15
teil13/fib.py
Normal file
15
teil13/fib.py
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
# fib.py
|
||||||
|
import sys
|
||||||
|
|
||||||
|
# berechnet rekursiv die Fibonaccizahl n.
|
||||||
|
def fib(n):
|
||||||
|
|
||||||
|
# Rekursionsbedingung
|
||||||
|
if n in [0,1]:
|
||||||
|
return 1
|
||||||
|
else:
|
||||||
|
# Rekursionsaufruf
|
||||||
|
return fib(n-1) + fib(n-2)
|
||||||
|
|
||||||
|
element = int(sys.argv[1])
|
||||||
|
print(fib(element))
|
65
teil13/fibclient.py
Normal file
65
teil13/fibclient.py
Normal file
@@ -0,0 +1,65 @@
|
|||||||
|
# encoding: utf-8
|
||||||
|
# fibclient.py
|
||||||
|
import socket
|
||||||
|
import time
|
||||||
|
#from network.const import __ADDRESSREMOTE__
|
||||||
|
#from network.const import __ADDRESSLOCAL__
|
||||||
|
from network import __ADDRESSLOCAL__
|
||||||
|
|
||||||
|
DISCONNECT_MESSAGE = "!DISCONNECT"
|
||||||
|
|
||||||
|
# Verbindung herstellen
|
||||||
|
def connect():
|
||||||
|
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
# für fibserver auf einem Remote-Pi
|
||||||
|
# client.connect(__ADDRESSREMOTE__)
|
||||||
|
# für fibserver auf lokalem Pi (import oben beachten!)
|
||||||
|
client.connect(__ADDRESSLOCAL__)
|
||||||
|
return client
|
||||||
|
|
||||||
|
# msg senden
|
||||||
|
def send(client, msg):
|
||||||
|
message = msg.encode('utf-8')
|
||||||
|
client.send(message)
|
||||||
|
|
||||||
|
# Daten empfangen
|
||||||
|
def receive(conn):
|
||||||
|
msg = conn.recv(64).decode('utf-8')
|
||||||
|
|
||||||
|
return msg
|
||||||
|
|
||||||
|
# Hauptmethode
|
||||||
|
def start():
|
||||||
|
# String von Console lesen
|
||||||
|
answer = input('Verbindung aufbauen? (ja/nein)? ')
|
||||||
|
if answer.lower() != 'ja':
|
||||||
|
return
|
||||||
|
|
||||||
|
# Verbindung aufbauen
|
||||||
|
connection = connect()
|
||||||
|
while True:
|
||||||
|
msg = input("Nachricht (q für quit): ")
|
||||||
|
|
||||||
|
# Bei Eingabe == 'q' Schleife beenden.
|
||||||
|
if msg == 'q':
|
||||||
|
break
|
||||||
|
# Sonst eingegeben String an Server senden.
|
||||||
|
send(connection, msg)
|
||||||
|
# und auf Ergebnis warten.
|
||||||
|
result = receive(connection)
|
||||||
|
print(f'result={result}')
|
||||||
|
|
||||||
|
# Fibonaccizahl isolieren.
|
||||||
|
fib = int(result.split('[')[0])
|
||||||
|
print(f'Fibonnaci-Zahl ist {fib}')
|
||||||
|
print(f'[RESULT] {result}')
|
||||||
|
|
||||||
|
|
||||||
|
# zum Beenden die Nachricht 'quit an den Server senden
|
||||||
|
send(connection, 'quit')
|
||||||
|
time.sleep(1)
|
||||||
|
print('Disconnected')
|
||||||
|
|
||||||
|
# Hauptprogramm: Client starten
|
||||||
|
if __name__ == '__main__':
|
||||||
|
start()
|
92
teil13/fibserver.py
Executable file
92
teil13/fibserver.py
Executable file
@@ -0,0 +1,92 @@
|
|||||||
|
#! /usr/bin/python3
|
||||||
|
|
||||||
|
import socket
|
||||||
|
import threading
|
||||||
|
from network import __ADDRESSLOCAL__
|
||||||
|
|
||||||
|
# Server-Socket aufbauen
|
||||||
|
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||||
|
|
||||||
|
#Socket an unsere Server-Adresse binden
|
||||||
|
server.bind(__ADDRESSLOCAL__)
|
||||||
|
|
||||||
|
# Set mit den verbundenen Clients
|
||||||
|
clients = set()
|
||||||
|
|
||||||
|
# Locks für den Zugriff auf das Set
|
||||||
|
clients_lock = threading.Lock()
|
||||||
|
|
||||||
|
# Unsere Arbeitsmethode: rekursive Fibonacci-Reihe
|
||||||
|
def fib(n):
|
||||||
|
|
||||||
|
# Rekursionsbedingung
|
||||||
|
if n in [0,1]:
|
||||||
|
return 1
|
||||||
|
else:
|
||||||
|
# Rekursionsaufruf
|
||||||
|
return fib(n-1) + fib(n-2)
|
||||||
|
|
||||||
|
#bearbeitet eine eingehende Connection annehmen, pro Client ein seperater Thread
|
||||||
|
def handle_connection(conn,addr):
|
||||||
|
print(f"[NEW CONNECTION] {addr} Connected")
|
||||||
|
|
||||||
|
try:
|
||||||
|
connected = True
|
||||||
|
while connected:
|
||||||
|
msg = conn.recv(64).decode('utf-8')
|
||||||
|
print(f'[RECEIVED] {msg}')
|
||||||
|
if not msg:
|
||||||
|
break
|
||||||
|
else:
|
||||||
|
if msg.startswith('fib:'):
|
||||||
|
element = int(msg[4:])
|
||||||
|
fibo = fib(element)
|
||||||
|
print(f'[SENDING] fib({element})={fibo}')
|
||||||
|
# Ergebnis an Client senden.
|
||||||
|
with clients_lock:
|
||||||
|
for c in clients:
|
||||||
|
c.sendall(f'{fibo}'.encode('utf-8'))
|
||||||
|
else:
|
||||||
|
pass
|
||||||
|
|
||||||
|
if msg == 'quit':
|
||||||
|
print('[DISCONNECT]')
|
||||||
|
connected = False
|
||||||
|
|
||||||
|
# with clients_lock:
|
||||||
|
# for c in clients:
|
||||||
|
# c.sendall(f"[{addr}] {msg}".encode('utf-8'))
|
||||||
|
|
||||||
|
finally:
|
||||||
|
# Clientverbindung abbauen und aus Set entfernen.
|
||||||
|
with clients_lock:
|
||||||
|
clients.remove(conn)
|
||||||
|
|
||||||
|
conn.close()
|
||||||
|
|
||||||
|
|
||||||
|
# Start des Servers
|
||||||
|
def start():
|
||||||
|
print('[SERVER STARTED]!')
|
||||||
|
# Horchen nach eingehender Verbindung
|
||||||
|
server.listen()
|
||||||
|
while True:
|
||||||
|
# Neue Verbindung annehmen
|
||||||
|
|
||||||
|
conn, addr = server.accept()
|
||||||
|
# Neuen Client in Set aufnehmen
|
||||||
|
with clients_lock:
|
||||||
|
print(f'[ADDING CONNECTION] {conn}')
|
||||||
|
clients.add(conn)
|
||||||
|
|
||||||
|
#Thread zur Bearbeitung des Requests starten.
|
||||||
|
thread = threading.Thread(target=handle_connection, args=(conn, addr))
|
||||||
|
thread.start()
|
||||||
|
|
||||||
|
#Hauptprogramm: Serverstart einleiten
|
||||||
|
if __name__ == '__main__':
|
||||||
|
start()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
11
teil13/get_requests.py
Normal file
11
teil13/get_requests.py
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
import requests
|
||||||
|
|
||||||
|
url = requests.get('https://raspithek.de')
|
||||||
|
|
||||||
|
|
||||||
|
data = url.text
|
||||||
|
|
||||||
|
|
||||||
|
print(data)
|
||||||
|
|
||||||
|
|
20
teil13/get_urllib.py
Normal file
20
teil13/get_urllib.py
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
# encoding: UTF-8
|
||||||
|
import urllib.request
|
||||||
|
|
||||||
|
# URL öffnen und Daten anfordern. Ohne spezielle Dateiangabe
|
||||||
|
# liefert der Webserver immer die index.html zurück.
|
||||||
|
fp = urllib.request.urlopen('https://raspithek.de')
|
||||||
|
|
||||||
|
# Daten auslesen
|
||||||
|
data = fp.read()
|
||||||
|
|
||||||
|
print(type(data))
|
||||||
|
# Die Daten sin vom Datentyp Bytes und müssen daher erst
|
||||||
|
# zum UTF-8 String umkodiert werden.
|
||||||
|
str = data.decode('utf8')
|
||||||
|
|
||||||
|
fp.close()
|
||||||
|
|
||||||
|
print(str)
|
||||||
|
|
||||||
|
|
554
teil13/index.html
Normal file
554
teil13/index.html
Normal file
File diff suppressed because one or more lines are too long
3
teil13/network/__init__.py
Normal file
3
teil13/network/__init__.py
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
from .const import __ADDRESSLOCAL__
|
||||||
|
from .const import __ADDRESSREMOTE__
|
||||||
|
|
10
teil13/network/code.py
Normal file
10
teil13/network/code.py
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
def receive(conn):
|
||||||
|
msg = conn.recv(64).decode('utf-8')
|
||||||
|
|
||||||
|
return msg
|
||||||
|
|
||||||
|
def send(client, msg):
|
||||||
|
message = msg.encode('utf-8')
|
||||||
|
client.send(message)
|
||||||
|
|
||||||
|
|
19
teil13/network/const.py
Normal file
19
teil13/network/const.py
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
#network/const.py
|
||||||
|
|
||||||
|
import socket
|
||||||
|
|
||||||
|
# TCP Port
|
||||||
|
__PORT__ = 6554
|
||||||
|
|
||||||
|
#Server-IP
|
||||||
|
# für den Server (immer localhost)
|
||||||
|
__SERVERLOCAL__ = socket.gethostbyname(socket.gethostname())
|
||||||
|
|
||||||
|
#für Server auf einem Remote-Pi
|
||||||
|
__SERVERREMOTE__ = socket.gethostbyname('gabbo')
|
||||||
|
|
||||||
|
# Server-Adresse (IP,Port)
|
||||||
|
#lokal
|
||||||
|
__ADDRESSLOCAL__ = (__SERVERLOCAL__,__PORT__)
|
||||||
|
#remote
|
||||||
|
__ADDRESSREMOTE__ = (__SERVERREMOTE__,__PORT__)
|
3
teil13/substring.py
Normal file
3
teil13/substring.py
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
|
||||||
|
|
||||||
|
print('fib:58'[4:])
|
5
teil13/test.py
Normal file
5
teil13/test.py
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
from network.const import __SERVER__
|
||||||
|
from network.const import __ADDRESS__
|
||||||
|
|
||||||
|
print(f'Server:{__SERVER__}')
|
||||||
|
print(f'Address:{__ADDRESS__}')
|
2
teil14/.gitignore
vendored
Normal file
2
teil14/.gitignore
vendored
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
./__pycache__
|
||||||
|
./network/__pycache__/*
|
4
teil14/conf.py
Normal file
4
teil14/conf.py
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
import logging
|
||||||
|
__LOGLEVEL__ = logging.DEBUG
|
||||||
|
|
||||||
|
|
5
teil14/test.log
Normal file
5
teil14/test.log
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
2023-04-29 13:11:26,397 [DEBUG] testlogging: DEBUG/Drucken wir vorbereitet
|
||||||
|
2023-04-29 13:11:26,397 [INFO] testlogging: INFO/Es werden 2 Seiten gedruckt
|
||||||
|
2023-04-29 13:11:26,397 [WARNING] testlogging: WARN/nicht genügend Papier im Drucker
|
||||||
|
2023-04-29 13:11:26,397 [ERROR] testlogging: ERROR/Drucker nicht gefunden.
|
||||||
|
2023-04-29 13:11:26,397 [CRITICAL] testlogging: CRITICAL/Drucker brennt
|
17
teil14/testlogging.py
Normal file
17
teil14/testlogging.py
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
import logging
|
||||||
|
from conf import __LOGLEVEL__
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)s [%(levelname)s] %(funcName)s: %(message)s',
|
||||||
|
# filename='test.log',
|
||||||
|
level=__LOGLEVEL__)
|
||||||
|
|
||||||
|
def testlogging():
|
||||||
|
print('testlogging() aufgerufen.')
|
||||||
|
logging.debug('DEBUG/Druckdaten werden gesendet.')
|
||||||
|
logging.info('INFO/Es werden 2 Seiten gedruckt')
|
||||||
|
logging.warning('WARN/nicht genügend Papier im Drucker')
|
||||||
|
logging.error('ERROR/Drucker nicht gefunden.')
|
||||||
|
logging.critical('CRITICAL/Drucker brennt')
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
testlogging()
|
2
teil15/.gitignore
vendored
Normal file
2
teil15/.gitignore
vendored
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
./__pycache__
|
||||||
|
./network/__pycache__/*
|
37
teil15/button.py
Executable file
37
teil15/button.py
Executable file
@@ -0,0 +1,37 @@
|
|||||||
|
#! /usr/bin/python3
|
||||||
|
import RPi.GPIO as GPIO
|
||||||
|
from time import sleep
|
||||||
|
import logging
|
||||||
|
|
||||||
|
|
||||||
|
__PIN__ = 16 # GPIO Pin, für den Taster
|
||||||
|
__WAIT__ = 0.5 # Warten für 0,5 Sekunden
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
|
||||||
|
if __name__ =='__main__':
|
||||||
|
GPIO.setwarnings(False)
|
||||||
|
# benutze Broadcom Pin Nummerierung
|
||||||
|
GPIO.setmode(GPIO.BCM)
|
||||||
|
|
||||||
|
logging.debug(f'konfiguriere Pin ${__PIN__} als Input.')
|
||||||
|
# Pin 16 als Input mit Pull-Up-Widerstand schalten.
|
||||||
|
GPIO.setup(__PIN__, GPIO.IN, pull_up_down=GPIO.PUD_UP)
|
||||||
|
pressed = False
|
||||||
|
|
||||||
|
logging.debug('Start der Schleife.')
|
||||||
|
try:
|
||||||
|
while True:
|
||||||
|
if not GPIO.input(__PIN__):
|
||||||
|
if not pressed:
|
||||||
|
logging.info('Button wurde gedrückt.')
|
||||||
|
pressed = True
|
||||||
|
else:
|
||||||
|
logging.debug('Button nicht gedrückt.')
|
||||||
|
pressed = False
|
||||||
|
|
||||||
|
sleep(__WAIT__)
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
logging.debug('Abbruch durch Benutzer.')
|
||||||
|
finally:
|
||||||
|
pass
|
||||||
|
|
50
teil15/led.py
Executable file
50
teil15/led.py
Executable file
@@ -0,0 +1,50 @@
|
|||||||
|
#! /usr/bin/python3
|
||||||
|
|
||||||
|
import RPi.GPIO as GPIO
|
||||||
|
from time import sleep
|
||||||
|
|
||||||
|
__PIN__ = 23 # GPIO Pin, den wir nutzen
|
||||||
|
__WAIT__ = 0.5 # Warten für 0,5 Sekunden
|
||||||
|
|
||||||
|
GPIO.setwarnings(False)
|
||||||
|
|
||||||
|
# benutze Broadcom Pin Nummerierung
|
||||||
|
GPIO.setmode(GPIO.BCM)
|
||||||
|
|
||||||
|
# Pin 23 als Output schalten.
|
||||||
|
GPIO.setup(__PIN__,GPIO.OUT)
|
||||||
|
|
||||||
|
#Zustand der LED setzen
|
||||||
|
def setLED(state):
|
||||||
|
|
||||||
|
GPIO.output(__PIN__,state)
|
||||||
|
|
||||||
|
# Dauerschleife, die die LED im Wechsel ein- und ausschaltet.
|
||||||
|
# Wird gestoppt mit CTRL-C
|
||||||
|
def blinkloop():
|
||||||
|
try:
|
||||||
|
while True:
|
||||||
|
|
||||||
|
# Pin auf HIGH setzen schaltet die LED ein
|
||||||
|
setLED(GPIO.HIGH)
|
||||||
|
print('LED ein')
|
||||||
|
|
||||||
|
sleep(__WAIT__)
|
||||||
|
|
||||||
|
# Pin auf LOW setzen schaltet die LED aus
|
||||||
|
setLED(GPIO.LOW)
|
||||||
|
print('LED aus')
|
||||||
|
sleep(__WAIT__)
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
pass
|
||||||
|
finally:
|
||||||
|
# Zum schluss immer die LED ausschalten.
|
||||||
|
setLED(GPIO.LOW)
|
||||||
|
|
||||||
|
if __name__ =='__main__':
|
||||||
|
blinkloop()
|
||||||
|
GPIO.cleanup(__PIN__)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
69
teil15/ledserver.py
Executable file
69
teil15/ledserver.py
Executable file
@@ -0,0 +1,69 @@
|
|||||||
|
#! /usr/bin/python3
|
||||||
|
from http.server import SimpleHTTPRequestHandler
|
||||||
|
import socketserver
|
||||||
|
import logging
|
||||||
|
from led import setLED
|
||||||
|
|
||||||
|
responsehtml = '<html><body> <h3>LED-Server</h3><p> LED ist $ledstate_str</p></body></html>'
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
|
||||||
|
# Da http ein stateless Protokoll ist, wird der Handler bei jedem Request neu
|
||||||
|
# aufgebaut! Deswegen benutzen wir hier setup() statt __init__()
|
||||||
|
class LEDHttpRequestHandler(SimpleHTTPRequestHandler):
|
||||||
|
def setup(self):
|
||||||
|
logging.debug('setting up Handler')
|
||||||
|
self.ledstate = False
|
||||||
|
super().setup()
|
||||||
|
|
||||||
|
def do_GET(self):
|
||||||
|
logging.debug(f'path= {self.path}')
|
||||||
|
logging.debug('GET: empfangen')
|
||||||
|
self.send_response(200)
|
||||||
|
self.send_header('Content-Type:','text/html')
|
||||||
|
# Ende der Header markieren, dass ist wichtig, sonst kommt der Response nicht zurück!
|
||||||
|
self.end_headers()
|
||||||
|
|
||||||
|
#Wenn im Requestpath 'led='on'enthalten ist, schalten wir die LED ein. Bei off aus
|
||||||
|
if '?led=' in self.path:
|
||||||
|
if 'on' in self.path:
|
||||||
|
logging.debug('schalte LED ein')
|
||||||
|
self.ledstate = True
|
||||||
|
setLED(self.ledstate)
|
||||||
|
elif 'off' in self.path:
|
||||||
|
logging.debug('schalte LED aus')
|
||||||
|
self.ledstate = False
|
||||||
|
setLED(self.ledstate)
|
||||||
|
|
||||||
|
logging.debug(f'ledstate={self.ledstate}')
|
||||||
|
|
||||||
|
response = responsehtml.replace('$ledstate_str',('aus','an')[self.ledstate])
|
||||||
|
|
||||||
|
self.wfile.write(response.encode())
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class http_server:
|
||||||
|
def __init__(self):
|
||||||
|
def handler(*args):
|
||||||
|
myHandler(*args)
|
||||||
|
server = HTTPServer(('', 8080), handler)
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
logging.debug('MAIN: start')
|
||||||
|
setLED(False) # Beim Start LED ausschalten
|
||||||
|
#Request-Handler aufbauen
|
||||||
|
handler = LEDHttpRequestHandler
|
||||||
|
handler.ledstate = False
|
||||||
|
#Socketserver mit unserem Handler starten
|
||||||
|
with socketserver.TCPServer(('',8080),handler) as httpd:
|
||||||
|
logging.info('SERVER: start')
|
||||||
|
try:
|
||||||
|
#Server läuft bis CTRL-C gedrückt wird.
|
||||||
|
httpd.serve_forever()
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
pass
|
||||||
|
finally:
|
||||||
|
setLED(False)
|
||||||
|
|
||||||
|
|
3
teil15/network/__init__.py
Normal file
3
teil15/network/__init__.py
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
from .const import __ADDRESSLOCAL__
|
||||||
|
#from .const import __ADDRESSREMOTE__
|
||||||
|
|
10
teil15/network/code.py
Normal file
10
teil15/network/code.py
Normal file
@@ -0,0 +1,10 @@
|
|||||||
|
def receive(conn):
|
||||||
|
msg = conn.recv(64).decode('utf-8')
|
||||||
|
|
||||||
|
return msg
|
||||||
|
|
||||||
|
def send(client, msg):
|
||||||
|
message = msg.encode('utf-8')
|
||||||
|
client.send(message)
|
||||||
|
|
||||||
|
|
19
teil15/network/const.py
Normal file
19
teil15/network/const.py
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
#network/const.py
|
||||||
|
|
||||||
|
import socket
|
||||||
|
|
||||||
|
# TCP Port
|
||||||
|
__PORT__ = 6554
|
||||||
|
|
||||||
|
#Server-IP
|
||||||
|
# für den Server (immer localhost)
|
||||||
|
__SERVERLOCAL__ = socket.gethostbyname(socket.gethostname())
|
||||||
|
|
||||||
|
#für Server auf einem Remote-Pi
|
||||||
|
#__SERVERREMOTE__ = socket.gethostbyname('gabbo')
|
||||||
|
|
||||||
|
# Server-Adresse (IP,Port)
|
||||||
|
#lokal
|
||||||
|
__ADDRESSLOCAL__ = (__SERVERLOCAL__,__PORT__)
|
||||||
|
#remote
|
||||||
|
#__ADDRESSREMOTE__ = (__SERVERREMOTE__,__PORT__)
|
2
teil16/.gitignore
vendored
Normal file
2
teil16/.gitignore
vendored
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
./__pycache__
|
||||||
|
./network/__pycache__/*
|
BIN
teil16/Fib-Testdaten.xlsx
Normal file
BIN
teil16/Fib-Testdaten.xlsx
Normal file
Binary file not shown.
13
teil16/fib.py
Normal file
13
teil16/fib.py
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
# fib.py
|
||||||
|
import sys
|
||||||
|
|
||||||
|
# berechnet rekursiv die Fibonaccizahl n.
|
||||||
|
def fib(n):
|
||||||
|
|
||||||
|
# Rekursionsbedingung
|
||||||
|
if n in [0,1]:
|
||||||
|
return 1
|
||||||
|
else:
|
||||||
|
# Rekursionsaufruf
|
||||||
|
return fib(n-1) + fib(n-2)
|
||||||
|
|
20
teil16/testfib.py
Normal file
20
teil16/testfib.py
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
from fib import fib
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
|
||||||
|
logging.debug('Test startet')
|
||||||
|
|
||||||
|
result5 = fib(5)
|
||||||
|
|
||||||
|
result8 = fib(8)
|
||||||
|
|
||||||
|
|
||||||
|
if result5 == 8 and result8 == 34:
|
||||||
|
logging.info('Tests erfolgreich')
|
||||||
|
else:
|
||||||
|
logging.error('Tests fehlerhaft')
|
||||||
|
|
||||||
|
logging.debug('Testende')
|
||||||
|
|
||||||
|
|
57
teil16/unittestfib.py
Normal file
57
teil16/unittestfib.py
Normal file
@@ -0,0 +1,57 @@
|
|||||||
|
# coding: utf-8
|
||||||
|
import unittest
|
||||||
|
import numbers
|
||||||
|
from fib import fib
|
||||||
|
import logging
|
||||||
|
import pandas as pd
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
|
||||||
|
class TestFib(unittest.TestCase):
|
||||||
|
|
||||||
|
# Methode zur Division a/b.
|
||||||
|
def divide(self, a,b):
|
||||||
|
if b == 0:
|
||||||
|
raise ValueError('Dividend darf nicht 0 sein.')
|
||||||
|
|
||||||
|
return int(a/b)
|
||||||
|
|
||||||
|
|
||||||
|
# Die setUp() Methode wird zu Beginn jedes Testcases aufgrufen
|
||||||
|
def setUp(self):
|
||||||
|
logging.debug('setting up test')
|
||||||
|
self.results = [1,1,2,3,5,8,13,21,34,55]
|
||||||
|
|
||||||
|
#die beiden Tests aus ./testfib.py mit unittest
|
||||||
|
def test_fib(self):
|
||||||
|
|
||||||
|
# assertEqual(n,r) testet, ob das Resultat r der Vorgabe n entspricht.
|
||||||
|
self.assertEqual(8,fib(5))
|
||||||
|
self.assertEqual(34,fib(8))
|
||||||
|
|
||||||
|
def test_mult_fib(self):
|
||||||
|
results =[1,1,2,3,5,8,13,21,34,55]
|
||||||
|
|
||||||
|
for n in range(0,9):
|
||||||
|
self.assertEqual(results[n],fib(n))
|
||||||
|
|
||||||
|
def test_divide(self):
|
||||||
|
|
||||||
|
self.assertEqual(2, self.divide(2,1))
|
||||||
|
self.assertEqual(2, self.divide(4,2))
|
||||||
|
self.assertEqual(3, self.divide(6,2))
|
||||||
|
|
||||||
|
with self.assertRaises(ValueError):
|
||||||
|
self.divide(1,0)
|
||||||
|
|
||||||
|
def test_excel(self):
|
||||||
|
data = pd.read_excel('./Fib-Testdaten.xlsx')
|
||||||
|
results = data["Ergebnis"]
|
||||||
|
|
||||||
|
for key, result in data.items():
|
||||||
|
if isinstance(key, numbers.Number): #Überspringen der Überschriftenzeile
|
||||||
|
self.assertEqual(result, fib(int(key)))
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
unittest.main()
|
3
teil17/.gitignore
vendored
Normal file
3
teil17/.gitignore
vendored
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
./__pycache__
|
||||||
|
./db.ini
|
||||||
|
./network/__pycache__/*
|
45
teil17/DBConnection.py
Normal file
45
teil17/DBConnection.py
Normal file
@@ -0,0 +1,45 @@
|
|||||||
|
#encoding: utf-8
|
||||||
|
import mysql.connector
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
class DBConnection():
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self.dbconnection = None
|
||||||
|
|
||||||
|
#Verbindung zur Datenbank mit den übergebenen Wreten herstellen.
|
||||||
|
def connect(self, host, user, password, database):
|
||||||
|
|
||||||
|
self.connection= mysql.connector.connect(host=host, user=user,password=password,database=database)
|
||||||
|
|
||||||
|
# Verbindung trennen
|
||||||
|
def disconnect(self):
|
||||||
|
if self.connection is not None:
|
||||||
|
self.connection.close()
|
||||||
|
self.connection = None
|
||||||
|
|
||||||
|
# Schüler-Record in die Tabelle einfügen.
|
||||||
|
def insertSchueler(self,schueler):
|
||||||
|
self.execute_query('insert into schueler (name,vorname) values(%s,%s)', (schueler['name'],schueler['vorname']))
|
||||||
|
|
||||||
|
# Liefert True, wenn die Verbindung zur DB besteht, sonst False
|
||||||
|
def isConnected(self):
|
||||||
|
if self.connection is not None:
|
||||||
|
return self.connection.is_connected()
|
||||||
|
return False
|
||||||
|
|
||||||
|
# Wenn DB-Verbindung besteht, wird der Cursor geliefert, sonst None
|
||||||
|
def cursor(self):
|
||||||
|
if self.isConnected():
|
||||||
|
return self.connection.cursor()
|
||||||
|
return None
|
||||||
|
|
||||||
|
# Datenbank Kommando ausführen. Das params-Tupel wird in die Query eingesetzt.
|
||||||
|
# Liefert ein Resultset zurück.
|
||||||
|
def execute_query(self, query, params = None):
|
||||||
|
if self.isConnected():
|
||||||
|
cursor = self.cursor()
|
||||||
|
if cursor is not None:
|
||||||
|
cursor.execute(query,params) #Kommdo ausführen
|
||||||
|
return cursor.fetchall() # Ergebnis zurückliefern.
|
BIN
teil17/__pycache__/DBConnection.cpython-39.pyc
Normal file
BIN
teil17/__pycache__/DBConnection.cpython-39.pyc
Normal file
Binary file not shown.
9
teil17/connectdb.py
Normal file
9
teil17/connectdb.py
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
from DBConnection import DBConnection
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
db_connection = DBConnection()
|
||||||
|
|
||||||
|
db_connection.connect('database','piuser','SW_Ep.6:ROTJ','pidb')
|
||||||
|
logging.debug(f'Datenbankverbindung aufgebaut ${db_connection.isConnected()}')
|
||||||
|
|
8
teil17/db.ini.sample
Normal file
8
teil17/db.ini.sample
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
[pidb]
|
||||||
|
host=database
|
||||||
|
user=piuser
|
||||||
|
password=<passwort>
|
||||||
|
database=pidb
|
||||||
|
|
||||||
|
|
||||||
|
|
88
teil17/testdb.py
Executable file
88
teil17/testdb.py
Executable file
@@ -0,0 +1,88 @@
|
|||||||
|
#!/usr/bin/python3
|
||||||
|
# encoding:utf-8
|
||||||
|
|
||||||
|
import unittest
|
||||||
|
from DBConnection import DBConnection
|
||||||
|
import logging
|
||||||
|
import configparser
|
||||||
|
|
||||||
|
logging.basicConfig( format='%(asctime)-15s [%(levelname)s] %(funcName)s: %(message)s', level=logging.DEBUG)
|
||||||
|
|
||||||
|
schueler = [
|
||||||
|
{'name':'Simpson','vorname': 'Bart'},
|
||||||
|
{'name':'Simpson','vorname':'Lisa'},
|
||||||
|
{'name':'van Houten','vorname':'Milhouse'},
|
||||||
|
{'name':'Wiggum','vorname':'Ralph'},
|
||||||
|
{'name':'Jones','vorname':'Jimbo'}
|
||||||
|
]
|
||||||
|
|
||||||
|
class TestDBConnection(unittest.TestCase):
|
||||||
|
|
||||||
|
@classmethod
|
||||||
|
def setUpClass(cls):
|
||||||
|
logging.debug(f'setUpClass() {cls}')
|
||||||
|
|
||||||
|
config = configparser.ConfigParser()
|
||||||
|
config.read('db.ini')
|
||||||
|
logging.debug(f"host={config['pidb']['host']}")
|
||||||
|
|
||||||
|
cls.db_connection = DBConnection()
|
||||||
|
cls.db_connection.connect(config['pidb']['host'],config['pidb']['user'],config['pidb']['password'],config['pidb']['database'])
|
||||||
|
if cls.db_connection.isConnected():
|
||||||
|
logging.debug('erzeuge Table schueler...')
|
||||||
|
cls.db_connection.execute_query('create table if not exists schueler (id int auto_increment primary key, vorname varchar(20),name varchar(20))')
|
||||||
|
|
||||||
|
# Testdaten aufbauen.
|
||||||
|
cls.fill_table()
|
||||||
|
logging.debug('setup() fertig')
|
||||||
|
|
||||||
|
@classmethod
|
||||||
|
def tearDownClass(cls):
|
||||||
|
logging.debug(f'tearDownClass() {cls}')
|
||||||
|
|
||||||
|
logging.debug('Räume Tables auf')
|
||||||
|
cls.db_connection.execute_query('drop table if exists schueler')
|
||||||
|
logging.debug('schliesse Datenbankverbindung.')
|
||||||
|
cls.db_connection.disconnect()
|
||||||
|
cls.db_connection = None
|
||||||
|
|
||||||
|
|
||||||
|
# input('Press Any Key')
|
||||||
|
|
||||||
|
#Testdaten in die Datenbank übertragen
|
||||||
|
@classmethod
|
||||||
|
def fill_table(cls):
|
||||||
|
for s in range(0,len(schueler)):
|
||||||
|
student = schueler[s]
|
||||||
|
cls.db_connection.insertSchueler(student)
|
||||||
|
|
||||||
|
# Nur die Records mit Nachname ='Simpson' lesen
|
||||||
|
def test_select_name(self):
|
||||||
|
self.assertTrue(self.db_connection.isConnected())
|
||||||
|
|
||||||
|
result = self.db_connection.execute_query("select * from schueler where name='Simpson'")
|
||||||
|
self.assertEqual(2,len(result))
|
||||||
|
|
||||||
|
def test_select_all(self):
|
||||||
|
# self.test_insert()
|
||||||
|
result = self.db_connection.execute_query("select * from schueler")
|
||||||
|
logging.debug(f'result={result}')
|
||||||
|
self.assertEqual(len(schueler),len(result))
|
||||||
|
|
||||||
|
for i in range(len(result)):
|
||||||
|
self.assertEqual(schueler[i]['vorname'], result[i][1])
|
||||||
|
|
||||||
|
def test_connected(self):
|
||||||
|
self.assertTrue(self.db_connection.isConnected())
|
||||||
|
|
||||||
|
|
||||||
|
def test_create_table(self):
|
||||||
|
self.assertTrue(self.db_connection.isConnected())
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ =='__main__':
|
||||||
|
unittest.main()
|
||||||
|
|
Reference in New Issue
Block a user