49 lines
1.6 KiB
Python
49 lines
1.6 KiB
Python
from time import sleep
|
|
from threading import Thread
|
|
from logging import getLogger
|
|
|
|
class FlaskPageThread(Thread):
|
|
def __init__(self, delay, func, *args, **kwargs):
|
|
name = kwargs.get("name", "FlaskPageThread")
|
|
self.delay = delay
|
|
self.func = func
|
|
self.args = args
|
|
self.page = ("init", 500)
|
|
self.healthy = False
|
|
self.retrycount = kwargs.get("retrycount", 3)
|
|
self.retrydelay = kwargs.get("retrydelay", 1)
|
|
self.log = kwargs.get("log", getLogger(name))
|
|
self.log.debug("FlaskPageThread.__init__(%s)" % name)
|
|
super().__init__(target=self.run, daemon=True, name=name)
|
|
|
|
def genpage(self):
|
|
c = self.retrycount
|
|
while c > 0:
|
|
c-=1
|
|
try:
|
|
self.log.debug("FlaskPageThread.genpage()")
|
|
data = self.func(*self.args)
|
|
self.page = (data, 200)
|
|
self.healthy = True
|
|
c=0
|
|
except Exception as e:
|
|
print("Exception: %s" % e)
|
|
if c == 0:
|
|
self.page = ("Internal error", 500)
|
|
self.healthy = False
|
|
else:
|
|
# retry
|
|
self.log.warn("FlaskPageThread.genpage(): Retry %s"
|
|
% self.name)
|
|
sleep(self.retrydelay)
|
|
|
|
def run(self):
|
|
self.log.debug("FlaskPageThread.run()")
|
|
self.genpage()
|
|
while True:
|
|
sleep(self.delay)
|
|
self.genpage()
|
|
|
|
if __name__ == "__main__":
|
|
pass
|