由于调度程序while循环python烧瓶，代码无法访问

Question

我正在尝试运行一个调度程序，我的索引函数将在每 1 分钟内运行。我正在使用烧瓶和 postgresql。但是在运行烧瓶运行之后 app.run() 未执行。这是代码：

 def index():
        connection = db.engine.connect(close_with_result=True)
        print('first')
    
        sql = text("""delete from user""")
        print('done')
        connection.execute(sql)
    
        connection = db.engine.connect(close_with_result=True)
    
        sql = text("""select * from user where name='a' or name='b'""")
        connection.execute(sql)
        connection.close()
        
 schedule.every(1).minutes.do(index)
 while True:
       schedule.run_pending()
       time.sleep(1)
    # scheduler wait for 1 second
    
 if __name__ == "__main__":
       app.run()

但似乎这段代码无法访问：

if __name__ == "__main__":
    app.run()

因为这部分代码：

while True:
        schedule.run_pending()
        time.sleep(1)
    # scheduler wait for 1 second

为什么它不起作用？

Answer 1

我认为您不能在使用 __main__ 函数的同一范围内运行阻塞循环。

我会说你要么创建一个线程来在后台运行带有阻塞循环的调度程序，要么你可以使用APScheduler。

from apscheduler.schedulers.background import BackgroundScheduler
    

def index():
    connection = db.engine.connect(close_with_result=True)
    print('first')

    sql = text("""delete from user""")
    print('done')
    connection.execute(sql)

    connection = db.engine.connect(close_with_result=True)

    sql = text("""select * from user where name='a' or name='b'""")
    connection.execute(sql)
    connection.close()

scheduler = BackgroundScheduler()
scheduler.add_job(func=index, trigger="interval", seconds=60)
scheduler.start()

if __name__ == "__main__":
    app.run()