我正在将Schedule
导入Flask
。我的项目包含WSGI
但是我对Flask
和WSGI
之间的关系知之甚少。现在我有三个主要文件:
wsgi.py
:由其他工具自动生成。app.py
:我把客户请求放在这里。test.py
:用于测试Schedule
。我想在服务器启动时启动一项任务,这是一项长期任务。这是wsgi.py
的一部分:
# -*- coding: utf-8 -*-
from threading import Thread
import test
t = Thread(target=test.job)
t.start()
if __name__ == '__main__':
...
如你所见,我开始一个线程,让工作在其中工作。这是我的test.py
。
import schedule
def job():
schedule.every(1).seconds.do(pr)
def pr():
print("I'm working...")
我的问题是job
永远不会开始。
我发现了我的问题。我从不让计划执行工作。现在wsgi.py
看起来像这样。
# -*- coding: utf-8 -*-
from threading import Thread
import test
schedule.every(1).seconds.do(test.job)
t = Thread(target=test.run_schedule)
t.start()
if __name__ == '__main__':
...
和test.py
:
import schedule
import time
start_time = time.time()
def job():
print("I'm working..." + str(time.time() - start_time))
def run_schedule():
while True:
schedule.run_pending()
time.sleep(1)
为了在单独的线程中工作,我创建了一个线程,在这个线程中我每1ms循环一次。在循环中,如果超时,schedule
调用run_pending
来调用job
(在我的情况下它是1s)。