Python Apscheduler 不停止函数执行

Question

我正在尝试执行人脸检测功能，并仅在特定时间使用 Apscheduler 运行该功能。我可以正确启动该功能，但 end_time 参数似乎根本不起作用，该功能一直保持运行ning 直到手动关闭。

这是开始行程的路线：

@app.route("/schedule/start", methods = ['POST'])
    def create():
        sched = BlockingScheduler()
        sched.add_job(detection, 'cron', start_date='2020-10-01 15:33:00', end_date='2020-10-01 15:33:05')

    sched.start()


    return 'Schedule created.'

我的 detection 函数中有一个 While True 条件，其中包含所有检测逻辑运行。难道这就是为什么我确定了停止时间它永远不会停止的原因吗？我该如何解决这个问题？

编辑。我的 detection 函数中的 while 循环（删除了不必要的部分）：

while True:
        
    frame = stream.read()

    frame = imutils.resize(frame, width=900)
    frame = cv2.cvtColor(frame, cv2.COLOR_BGR2GRAY)
    frame = np.dstack([frame, frame, frame])
    # frame = cv2.flip(frame, 0)
    faces = faceCascade.detectMultiScale(
                        frame,
                        scaleFactor=1.1,
                        minNeighbors=3,
                        # minSize=(10, 10),
                        # maxSize=(50, 50),
                        # flags=cv2.CASCADE_SCALE_IMAGE
                )

    for (x, y, w, h) in faces:
        name = str(currentframe) + '.jpg'
        print('Creating...' + name)
        cv2.imwrite(os.path.join(parent_dir, name), frame)

        currentframe += 1

        if cv2.waitKey(1) & 0xFF == ord('q'):
            break

编辑2。我按照下面的建议尝试并收到此错误：TypeError: func must be a callable or a textual reference to one.

我还想集成手动启动和停止面部检测功能的功能。我可以这样做：

@app.route("/start", methods = ['POST'])
def start():
    os.environ['run'] = 'running'
    detection()

    return 'Detection started'


@app.route("/stop", methods = ['POST'])
def stop():
    os.environ['run'] = 'stop'    

    return 'Detection stopped.'

然后在我的 detection.py 中，我只是检查 while 循环开始时的环境变量：

while True:
        if os.environ.get('run') == 'stop':
            stream.stream.release()
            exit()

我想要的是将日程安排功能集成到此。我不想创建单独的功能，因为我希望能够手动停止按计划启动的检测。有什么技巧可以实现吗？

编辑3。该计划现在正在运作。手动启动也有效，停止工作意味着它停止检测面部。以 schedule 开始的函数仍然继续运行，它只是根本不迭代到检测部分，因为有一个 os.environ['run'] = 'stop' -flag。知道如何停止函数执行吗？这是我的 while 循环检查：

while True:
    if self.end_date <= datetime.now() or os.environ.get('run') == 'stop':
        stream.stream.release()
        exit()

当手动启动时，停止功能正常工作，但当停止计划作业时，它会一直循环直到 end_date 时间到达。

Answer 1

你需要有一些条件来结束你的 while 循环，因为它现在是无限的，传递 start/end 次并转换为 date-time 并尝试匹配 while end_date_time =< now: 然后退出任务.如果您需要传递 start/end 日期，也许将您的 detection 函数转换为 class 并在初始化时传递 end_date 当您希望您的 cron 作业停止时。

# detection.py
from datetime import datetime

class Detection:
    def __init__(self, end_date):
        self.end_date = datetime.strptime(end_date, '%Y-%m-%d %H:%M:%S.%f')

    def detection(self):
        print(self.end_date)
        while self.end_date <= datetime.utcnow():
            print('works')



# routes.py
# And then do it like this when starting cron
import Detection

def create():
    start_date = '2020-10-02 01:48:00.192386'
    end_date = '2020-10-02 05:50:00.192386'
    dt = Detection(end_date)
    sched = BlockingScheduler()
    sched.add_job(dt.detection, 'cron', start_date=start_date, end_date=end_date)

    sched.start()


    return 'Schedule created.'

这应该可以解决问题

Python Apscheduler 不停止函数执行

Python Apscheduler not stopping function execution

python

scheduled-tasks

flask

apscheduler