Threads laufen zweimal mit Flask

oelkanne · Mar 1st 2020

An die Python Gemeinde,

Im Beitrag Kann man den Inhalt einer Python variable nach PHP übergeben? habe ich erste Schritte mit Flask gemacht. Das funktioniert auch soweit.

Nun bei der Umsetzung des gelernten habe ich das Problem, dass meine dazu gebauten Threads zweimal gestartet werden.

Hier ein vereinfachter Code zur Demonstration und die dazugehörige Konsolenausgabe.

Meine Frage: Woran liegt das? – in der Hoffnung einige Codezeilen zur Lösungsfindung zu bekommen.

Python

#!/usr/bin/python
# -*- coding: utf-8 -*-  
from flask import Flask, jsonify                 
import time                                      
import threading                                                              
import datetime                                  

 
def Thread_1():
  print time.strftime("%d.%m.%Y - %H:%M:%S Uhr") + ' Starte Thread_1'
  while OK:
    time.sleep(30)
    print time.strftime("%d.%m.%Y - %H:%M:%S Uhr") + ' Thread_1 - ping/30s'
 
 
def Thread_2():
  print time.strftime("%d.%m.%Y - %H:%M:%S Uhr") + ' Starte Thread_2'
  while OK:
    time.sleep(30)
    print time.strftime("%d.%m.%Y - %H:%M:%S Uhr") + ' Thread_2 - ping/30s' 


OK= True
Unterprogramm_Thread_1=threading.Thread(target=Thread_1)
Unterprogramm_Thread_2=threading.Thread(target=Thread_2)
Unterprogramm_Thread_1.start()   
Unterprogramm_Thread_2.start()       
  
app   = Flask( __name__ )
@app.route( "/uhrzeit" )
def uhrzeit():
    now        = datetime.datetime.now()
    timeString = now.strftime("%Y-%m-%d %H:%M:%S")
    response   = jsonify( {"uhrzeit": timeString} )
    response.headers.add( "Access-Control-Allow-Origin", "*" )
    return response
    
if __name__ == "__main__":
   app.run(host='0.0.0.0', port=9000, debug=True)

Display More

Konsolenausgabe:

Code

root@RP1-Solarthermie:/home/pi# python forum.py
01.03.2020 - 16:51:08 Uhr Starte Thread_1
01.03.2020 - 16:51:08 Uhr Starte Thread_2
 * Serving Flask app "forum" (lazy loading)
 * Environment: production
   WARNING: This is a development server. Do not use it in a production deployment.
   Use a production WSGI server instead.
 * Debug mode: on
 * Running on http://0.0.0.0:9000/ (Press CTRL+C to quit)
 * Restarting with stat
01.03.2020 - 16:51:13 Uhr Starte Thread_1
01.03.2020 - 16:51:13 Uhr Starte Thread_2
 * Debugger is active!
 * Debugger PIN: 734-062-809
01.03.2020 - 16:51:38 Uhr Thread_1 - ping/30s
01.03.2020 - 16:51:38 Uhr Thread_2 - ping/30s
01.03.2020 - 16:51:43 Uhr Thread_1 - ping/30s
01.03.2020 - 16:51:43 Uhr Thread_2 - ping/30s
01.03.2020 - 16:52:08 Uhr Thread_1 - ping/30s
01.03.2020 - 16:52:08 Uhr Thread_2 - ping/30s
01.03.2020 - 16:52:13 Uhr Thread_1 - ping/30s
01.03.2020 - 16:52:13 Uhr Thread_2 - ping/30s
01.03.2020 - 16:52:38 Uhr Thread_1 - ping/30s
 01.03.2020 - 16:52:38 Uhr Thread_2 - ping/30s
01.03.2020 - 16:52:43 Uhr Thread_1 - ping/30s
01.03.2020 - 16:52:43 Uhr Thread_2 - ping/30s
01.03.2020 - 16:53:08 Uhr Thread_1 - ping/30s
 01.03.2020 - 16:53:08 Uhr Thread_2 - ping/30s
01.03.2020 - 16:53:13 Uhr Thread_1 - ping/30s
01.03.2020 - 16:53:13 Uhr Thread_2 - ping/30s
01.03.2020 - 16:53:38 Uhr Thread_1 - ping/30s
 01.03.2020 - 16:53:38 Uhr Thread_2 - ping/30s
01.03.2020 - 16:53:43 Uhr Thread_1 - ping/30s
01.03.2020 - 16:53:43 Uhr Thread_2 - ping/30s

Display More

MistyFlower59469 · Mar 1st 2020

Du startest zwei Threads, und die laufen dann. Was genau erwartest du das anders wäre?

Und den Code zu kopieren, nur weil mal eine 1 und mal eine 2 drin vorkommt ist etwas sehr umständlich. Dazu einfach EINE Funktion mit Argument schreiben, und das Argument dem thread zum Start mitgeben.

oelkanne · Mar 1st 2020

In der finalen Version werden 8 Threads mit unterschiedlichen Aufgaben laufen – aber jeder Thread darf natürlich nur einmal existieren; nicht zweimal.

Die gezeigte Version ist zu Demonstrationzwecken.

Thread_1 startet zweimal und läuft auch zweimal. Dasselbe gilt für Thread_2

E sieht so aus, dass der zweite Start der Threats nach der Flaskausgabe „Restarting with stat“ erfolgt.

MistyFlower59469 · Mar 1st 2020

ahh. Jetzt sehe ich das. Ich vermute stark das hat was mit deiner IDE oder ggf. dem Flask Server im debug modus zu tun. Versuch das mal über die Kommandozeile zu starten. Ggf mit disableten debugger. Und es ist auch ein schlechtes Vorgehen, threads einfach auf Modulebene zu starten. Mach das sauber in einer Funktion, und ruf die in main auf. Das kann darauf auch einen Einfluss haben.

Und zu guter letzt: du machst garantiert einen Fehler, wenn du so viele threads laufen lassen willst. Maximal einer. Der muss dann ggf mehrere Aufgaben erledigen, aber ich verspreche dir, mit so vielen Threads verhedderst du dich.

noisefloor · Mar 2nd 2020

Hallo,

statt das "OK" auf oberster Ebene zu nutzen solltest du threading.Event benutzen, um den Thread etwas "mitzuteilen". Der ist der besserer und sauberer Weg.

Gruß, noisefloor

oelkanne · Mar 2nd 2020

Quote

Versuch das mal über die Kommandozeile zu starten. Ggf mit disableten debugger.

Super, klappt!

Quote

Und es ist auch ein schlechtes Vorgehen, threads einfach auf Modulebene zu starten. Mach das sauber in einer Funktion, und ruf die in main auf.

Hm, ich bin nicht genug Pytonianer, um zu verstehen was du meinst. Mein Hauptprogramm besteht aus

Try: hier werden all Threads gestartet und auch Flask

Except: Keyboard Interrupts, ... abzufangen

Finally: Um Gpios, Filehandler, ... zurückzusetzten

Mit den Sachen ___main___ usw. kenne ich mich gar nicht aus. Ist das was mit objektorientierter Programmierung? (kenne ich nur als Schlagwort)

Quote

Und zu guter letzt: du machst garantiert einen Fehler, wenn du so viele threads laufen lassen willst. Maximal einer. Der muss dann ggf mehrere Aufgaben erledigen, aber ich verspreche dir, mit so vielen Threads verhedderst du dich.

Die Treats laufen alle autark. Einzige Schnittmenge is das loggen.

Quote

statt das "OK" auf oberster Ebene zu nutzen solltest du threading.Event benutzen, um den Thread etwas "mitzuteilen". Der ist der besserer und sauberer Weg.

Die OK Methode hat mich auch schon immer gestört, kannte bisher keine Alternative. Dasmit dem threading.Event schaue ich mir mal genauer an.

MistyFlower59469 · Mar 2nd 2020

Mit Objekt Orientierung hat das nichts zu tun. Nur mit Ordnung und Klarheit. Man kann die Stromleitung diagonal durch die Wand ziehen. Macht man aber nicht. Code der auf Modul-Ebene steht macht Probleme. Weil man nicht entscheiden kann, wann der läuft. Und das kann dann schnell in die Hose gehen. Darum schreibt man Funktionen und ruft die kontrolliert auf.

Und ich bezweifle immer noch, dass du 8 Threads brauchst. Was machen die denn genau?

oelkanne · Mar 4th 2020

Hier mal zum reinschauen: http://91.67.114.141/page_hydr…ge_hydraulischer_plan.php

Python

#!/usr/bin/python
# -*- coding: utf-8 -*-  
import MySQLdb                                    # für Datenbank
import sys                                        # für Bildschirmausbage in Datei
import os                                         # für File exists Abfrage 
import time                                       # für Warteschleifen
import threading                                  # für Unterprogramme
import RPi.GPIO as GPIO                           # für Ein- und Ausgaben
import math                                       # für Sonnenauf- und untergangberechnung
import subprocess                                 # zum Abschalten der Unterprogramme
import datetime                                   # zur Überprüfung des Datenbankzeitstempel
# from Solar_GPIOs_abfragen_sub import *
#-----------------------------------------------------------------SETTINGS----------------------------------------------------------------------------
# Dateien
mess_file='Solar_GPIOs_abfragen.txt'              # Mengenergebnisse zyklisch dem Datenbankprg übergeben
Ausgabe_file='Solar_GPIOs_abfragen.log'           # Log Meldungen für Status ausgeben
Ausgabe_file2='Solar_crontab.log'                 # Log Meldungen für Messdaten
config_file='Solar_config.txt'                    # Konfiguartionsfile
GPIO_file='Solar_GPIOs_abfragen.txt'              # Ausgabe des GPIO Status                                          
# Bereiche für T Plausibiliät
dead_max = 80
dead_min = -50
dead_hi = -0.02                                   # -0.02
dead_lo = -0.08
T_oben_max = 65                                   # Max Speichertemperatur (wenn erreicht, dann Schwimmbadbetrieb bzw. abschalten, default 65)
T_oben_min = 60                                   # Min Speichertemperatur (w#
......
--------------------------------------------------------------------HAUPTPROGRAMM -------------------------------------------------------------------
save_stderr = sys.stderr                             # Fehlermeldungen in Datei umleiten 
fh = open("errors.txt","a")
sys.stderr =  time.strftime("%d.%m.%Y - %H:%M:%S Uhr"), fh

Unterprogramm_Log=threading.Thread(target=Log)
Unterprogramm_Mengenmessungen=threading.Thread(target=Mengenmessungen)
Unterprogramm_Sonnenauf_untergang=threading.Thread(target=Sonnenauf_untergang)
Unterprogramm_Solarkreis=threading.Thread(target=Solarkreis)
Unterprogramm_Zirkulation=threading.Thread(target=Zirkulation)
Unterprogramm_Datenbankmessungen=threading.Thread(target=Datenbankmessungen)
Unterprogramm_Heizungsunterstuetzung=threading.Thread(target=Heizungsunterstuetzung)

try:
  GPIOs_setzen()
  Unterprogramm_Sonnenauf_untergang.start()         # Unterprogramm für Sonnenaufgang und Untergang starten
  Unterprogramm_Zirkulation.start()                 # Unterprogramm für Zirkulationspumpe starten
  Unterprogramm_Solarkreis.start()                  # Unterprogramm für Solarkreis starten
  Unterprogramm_Mengenmessungen.start()             # Unterprogramm für Mengenmessungen starten
  Unterprogramm_Log.start()                         # Unterprogramm für Log file starten
  Unterprogramm_Datenbankmessungen.start()          # Unterprogramm für Datenbankmessungen starten
  Unterprogramm_Heizungsunterstuetzung.start()      # Unterprogramm für Heizungsunterstuetzung starten  
  while OK:
    ..........
   
except KeyboardInterrupt:
  GPIO.cleanup()
  jetzt = time.strftime("%d.%m.%Y - %H:%M:%S Uhr") 
  file_Ausgabe = open(Ausgabe_file,"a")
  file_Ausgabe.write(jetzt + "  Programm beendet. Grund: Abbruch durch User\n") 
  #sys.stdout = save_stdout   # Ausgabe zurück auf Bilschirm
  sys.stderr = save_stderr
  fh.close()
  OK = False
  print " Abbruch"
  
except:  
  GPIO.cleanup(); time.sleep(1); GPIOs_setzen()             
  jetzt = time.strftime("%d.%m.%Y - %H:%M:%S Uhr")
  file_Ausgabe = open(Ausgabe_file,"a") 
  file_Ausgabe.write(jetzt + "  Programm beendet. Grund: Fehler - reboote..\n") 
  sys.stdout = save_stdout   # Ausgabe zurück auf Bilschirm
  sys.stderr = save_stderr
  fh.close()
  os.system("reboot")
    
finally:  
  OK=False
  GPIO.setmode(GPIO.BOARD) 
  GPIO.cleanup()
  time.sleep(5)
  sys.exit(1)
  GPIO.cleanup(); time.sleep(1); GPIOs_setzen()             # this ensures a clean exit
  jetzt = time.strftime("%d.%m.%Y - %H:%M:%S Uhr")
  file_Ausgabe = open(Ausgabe_file,"a")
  file_Ausgabe.write(jetzt + "  Programm beendet. Grund: fertig\n") 
  sys.stdout = save_stdout   # Ausgabe zurück auf Bilschirm
  sys.stderr = save_stderr
  fh.close()

Display More

MistyFlower59469 · Mar 4th 2020

Na der entscheidende Teil wäre ja zu sehen, was die Threads wirklich TUN. Ob die sich dabei nicht in die Quere kommen, bzw. so viele sein müssen.

noisefloor · Mar 5th 2020

Hallo,

du nutzt noch Python 2 - das ist seit dem 1.1.2020 ohne Support durch die Entwickler von Python. D.h. du solltest dringend auf Python 3 umstellen.

Der gezeigte Code ist doch gar nicht lauffähig, weil in Zeile 50 das `OK` nicht definiert ist.
Alles ab Zeile 80 wird nicht ausgeführt, weil davor ein `sys.exit()` steht.
`os.system` in Zeile 72 ist veraltet, `subprocess` ist Stand der Dinge.
Wenn der `except` Block betreten wird, wird der `finally` Block nicht ausgeführt, weil das `os.system("reboot")` den Programmfluss an der Stelle stoppt.
Nackte `except` sind fast immer falsch, weil du damit _alle_ Fehler abfängst, auch Programmierfehler. Will man aber in der Regel gar nicht, weil das zu unerwarteten und nicht nachvollziehbaren Verhalten des Programms führen kann.

Kurz: da ist noch erhebliches Verbesserungspotential...

Gruß, noisefloor

Tags