Hallo, danke für das kleine Bsp. ... stream = self.request.makefile('rb') ... ich wusste nicht das makefile direkt zum Socket gehört. Ich dachte das wär komplett etwas eigenständiges. Ein komplett anderer Aufbau. Gestern mit den begriffen gesucht was das ist. Konnte da nichts finden. Erst jetzt gese...

Hallo Sirius3 den Code hatte ich gestern schon mitgeteilt. Gerne hier nochmals zusammengefasst, incl. wie ich nun mit dem bytearray arbeite. Können andere evtl. damit noch was anfangen. Ich Frage trotzdem. Warum heißt es "Du hast jetzt einen Weg gefunden, mit recv zu arbeiten, der anscheinend f...

Hallo, ich Antworte mir mal selbst. Gestern fast Punkt 0:00 Uhr umgesetzt, lief 30min... Dann doch noch ein Fehler. ( leider keine Debug Output an dieser Stelle gehabt :( ) Zwar ist dieser Fehler bis jetzt nicht nochmals vorgekommen, dafür ein anderer, welchen ich heute nachvollziehen und korrigiere...

Hallo __deets__ ja, darum wirke ich mit dem Puffer entgegen. Erst alles Sammeln, dann auswerten und wenn unvollständig auf nächste Daten warten. Bei dem nächsten durchlauf, prüfe ich ja wieder auf Vollständigkeit und arbeite erst dann weiter. Das ich vorher direkt auf self.request.recv(2048) gegange...

Hallo Sirius3, danke für dein Feedback. Aktuell nur ein Socket, da noch im Aufbau. Später ja, werden es mehrere parallele Sitzungen. (habe ich aktuell gar nicht mal mehr daran gedacht) Aktuell rufe ich es so auf... und es funktioniert auch wunderbar wie es soll. (aktuell nur mit einer Verbindung/Soc...

Hallo, danke, dafür habe ich mir reinen TCP-Stream bisher wenig zu tun gehabt. data_raw = self.request.recv(2048) data_puffer.extend(data_raw) Kann man sagen, dass der Anfang immer aus dem Header besehen muss? Natürlich bearbeite ich "data_puffer" indem ich komplette Daten identifiziere un...

Hallo, ich habe gerade einiges probiert und auch irgendwo (glaube ich) gelesen zu haben, dass es so nicht möglich seien soll. Meine erste Idee war ein einfacher Weg über .pattern. Habe ich dann aber schnell verworfen, da für meinen Fall es doch zu unflexibel ist. Jetzt bin ich auf Regex übergegangen...

Hallo, und wie versprochen, ich berichte... __init__.py Hier hat sich nicht viel verändert... Thread starte ich aus create_app() heraus. from flask import Flask from . import models SSH_LOCAL_PORT = 12345 def create_app(): app_ini = Flask(__name__) from threading import Thread from app import watchd...

Hallo __blackjack__, danke auch für deinen Beitrag. Ja, ok. Webserver, AppServer, DB etc... zähle ich nicht zu dem eigen geschriebenen Script :) Vielleicht muss ich mich da etwas von "meiner" Idee verabschieden... Aber wird wirklich, bei größeren Projekten, so viel händisch angelegt. Also ...

Guten Abend, Den relevanten Code zum Frontend hast du immer noch nicht gezeigt. Solange wirst du auch mit deinem 504 Problem alleine bleiben. Hier nun der Frontend Teil. Aber an dem liegt es nicht. Denn wenn der vorherige Teil "prüfung auf DB Verbindung" wegfällt. Läuft alles andere, bis a...

Hi, Achtung, es wird wieder "Hypothetische". Nein jetzt wirklich im Ernst, genau in diesem einen Fall ist die Funktion/Programm losgelöst, ja. Aber sehr oft steht der Background Task direkt mit dem Programm im Zusammengang. Also nein, es ist nicht nur ein Hypothetische Problem. Weil...? Al...

Hallo noisefloor, ok. Darum aber meinte ich auch, nicht betrachten das dieser Teil "eigentlich" unabhängig laufen kann. Mit ... einen unabhängigen Prozess auslagern. ... meine ich zu verstehen. Für dieses Programm ein eigenen "systemd" einrichten? Genau, dies möchte ich, wenn es ...

Hallo noisefloor, danke für deine Rückmeldung. das mit dem Einstiegspunkt dachte ich mir schon, darum ist auch der Prozess welchen ich testweise aus __main__ gestartet habe, nie aktiv geworden. Macht auch Sinn. Ja x Worker, da kommt aber der Punkt welchen ich nicht verstehe. Bei uWSGI-Appserver heiß...

Um es gleich vorweg zu nehmen. Ich bin auf eine Lösung gekommen (kommt am Ende). Auch wenn ich es lieber direkt in Python integriert hätte. (ohne abhängigkeit von uWSGI) Jetzt etwas ausführlicher, sollte jemand das gleiche Problem haben. Grobe Sache um was es geht "Stichworte" damit der Nä...

Hi, und ich war mir sicher, jetzt kann nicht mehr viel kommen ... Doch, das ist so falsch. Weil es immer noch die schon von __blackjack__ angesprochene Lücke zwischen Test und Update hat. Da ist noch genau gar nichts gewonnen. Der richtige Weg beinhaltet vorher die Tabelle mit select for update zu s...

Hallo und einen guten Abend, sry, an ein bsp. hatte ich heute mittag nicht mehr gedacht. Ist aber nichts großartiges. @home_blueprint.route('/test', methods=['GET']) def test(): thread_name = 'force_update' if not TP.ForceUpdate().status_check()[0]: # PRÜFE OB PROZESS GERADE LÄUFT TP.ForceUpdate().s...

Hallo an allen und danke für eure Antworten. Ich habe mich nun für die Variante, die schon vorhandene DB dafür zu nutzen, entschieden. ... Installier dir Celery, und gut ist. Ich habe dies mir kurz angesehen. Wenn man es im größeren Umpfang nutzt, dann sicherlich super. Celery benötigt einen Broker,...

Hallo __blackjack__, danke für deine Antwort. @chris_adnap: @chris_adnap: Man sollte keine kryptischen Abkürzungen verwenden. Wenn man `thread` meint, nicht nur `th` schreiben. Das kann man mit `any()` deutlich kompakter ausdrücken: Nachdem mann zig Sachen/Kombinationen/Möglichkeiten ausprobiert hat...

Hallo, ich antworte mir mal selbst :D Vor 1 Std bin ich auf "eine" Lösung gekommen... Ich prüfe nicht mit "..is_alive()" sondern gebe dem Kind einen Namen. Hier nun "force_update" und damit kann ich Thread übergeifend prüfen, ob dieser aktiv/oder nicht ist. def test(): ...

Hallo, ich komme zu keiner Lösung. Ich habe eine lauende Flask Applikation. Bisher funktioniert alles. Diese ruft von einer externen Seite Daten ab, bereitet diese auf, und gibt dies aus. (Also nichts neues) "Daten von externen", es werden immer nur Daten seit dem letzten Abruf nachgeladen...