如何同时使用“计划”和“运行”

Question

我有一个运行作业的计划脚本：

schedule.every(3).seconds.do(jobCheckSmth)

while True:
    schedule.run_pending()
    time.sleep(1)

我想使用 Web 界面来检查它的状态，而不是使用 CLI 上的 print()

run(host='localhost', port=80, debug=True)

但它会阻止代码执行，所以我必须按 Ctrl-C 来打破 webserver 循环以继续运行 while 循环

Bottle v0.12.18 server starting up (using WSGIRefServer())...
Listening on http://localhost:80/ Hit Ctrl-C to quit.

Answer 1

这是一个非常适合我使用 gevent 将瓶子变成异步的示例。要么是这个，要么你必须在你的瓶子应用程序之外的它自己的线程中运行schedule。但老实说，你应该这样做。

import gevent
from gevent import monkey,spawn as gspawn, sleep as gsleep, socket, signal_handler as sig
monkey.patch_all()
import signal
import arrow
from bottle import Bottle, static_file, get, post, request, response, template, redirect, hook, route, abort
from gevent.pywsgi import WSGIServer
from geventwebsocket.handler import WebSocketHandler

def start():
    def start_thread():
        set()
        while 1:
            try:
                schedule.run_pending()
            except:
                logger.exception('Scheduler Exception')
            gsleep(5) # This is the polling cycle for pending jobs
    print('Scheduler Started...')
    gspawn(start_thread)

def sample():
    gspawn(jobCheckSmth)

def set():
    # schedule.every(180).seconds.do(func)
    schedule.every().day.at("00:00").do(sample)
    logger.info('Started Schedule at {}'.format(arrow.now()))

@get('/')
def app():
    return 'Hello World!'

 if __name__ == '__main__':
    scheduler.start()
    botapp = bottle.app()
    server = WSGIServer(("0.0.0.0", int(port)), botapp , handler_class=WebSocketHandler)
    def shutdown():
        print('Shutting down ...')
        server.stop(timeout=60)
        exit(signal.SIGTERM)
    sig(signal.SIGTERM, shutdown)
    sig(signal.SIGINT, shutdown)
    server.serve_forever()