Flask中的ap调度程序执行两次[重复]

Question

我在烧瓶应用程序中使用apscheduler时遇到问题。

在我的view.py档案里我是这样写的

import time
from apscheduler.scheduler import Scheduler

def test_scheduler():
     print "TEST"
     print time.time()


sched = Scheduler()
sched.add_interval_job(test_scheduler, seconds=5)
sched.start()

然后这个方法test_scheduler（）每五秒钟执行两次

测试1360844314.01测试1360844314.2

Answer 1

您可以在Flask的before\u first\u request（）decorator中启动调度程序，该decorator“在应用程序的这个实例的第一个请求之前注册要运行的函数”。

import time
import atexit

from apscheduler.schedulers.background import BackgroundScheduler


def print_date_time():
    print(time.strftime("%A, %d. %B %Y %I:%M:%S %p"))


@app.before_first_request
def init_scheduler():
    scheduler = BackgroundScheduler()
    scheduler.add_job(func=print_date_time, trigger="interval", seconds=3)
    scheduler.start()
    # Shut down the scheduler when exiting the app
    atexit.register(lambda: scheduler.shutdown())

请注意，在服务器重新加载后，第一个请求总是会再次调用before\u first\u request（）。

Answer 2

使用重新加载程序时，有主进程和子进程。您的调度程序线程在这两者中都运行。您需要防止调度程序在主进程中运行

if not app.debug or os.environ.get('WERKZEUG_RUN_MAIN') == 'true':
  sched = Scheduler()
  sched.add_interval_job(test_scheduler, seconds=5)
  sched.start()

Answer 3

在调试模式下，Flask的重新加载程序将加载Flask应用程序两次（如何阻止Flask在调试模式下初始化两次？）。我不确定这是为什么，但它会导致apscheduler的作业被调度两次。一个快速打印“加载的调度程序”就在调度之前。start（）确认了这一点。

有几种方法可以解决这个问题，正如链接的答案中提到的。我发现最有效的方法就是像这样禁用重新加载器：

app.run(use_reloader=False)

这意味着我必须在开发应用程序时手动重新加载它，但要让apscheduler正常工作，付出的代价很小。