APScheduler BackgroundScheduler无法后台运行问题求助

在Ubuntu 22.04.1虚拟环境中用Python 3.10.12开发，基于Click和APScheduler的BackgroundScheduler实现定时任务CLI工具。打包后执行start命令时终端被阻塞，必须按Ctrl+C才能退出，期望执行start后立即释放终端，进程后台运行，直到手动执行stop停止。

当前代码存在两个核心问题：

• start_scheduler中的while True: pass循环阻塞主线程，导致终端无法释放
• 全局scheduler实例无法跨进程共享，stop和status命令无法识别后台运行的真实进程

步骤1：修正setup.py语法错误 #

首先修复entry_points中start行末尾缺失的逗号（否则打包会失败）：

""" This file is used for packaging the source code and command line interface"""

from setuptools import setup

setup(
    name='test_package',
    version='0.1.0',
    packages=['my_pack'],
    install_requires=['click','APScheduler'],
    entry_points={
        'console_scripts': [
            'start = my_pack.cli:start_scheduler',
            'status = my_pack.cli:status_scheduler',
            'stop = my_pack.cli:stop_scheduler',
        ],
    },
)

步骤2：重构cli.py实现后台运行与进程控制 #

通过PID文件管理进程+守护进程化实现需求，同时支持start/stop/status命令的跨进程控制：

import click
import os
import signal
import sys
from apscheduler.schedulers.background import BackgroundScheduler

# 定义PID文件路径（可根据需求修改，建议放在用户目录或/var/run）
PID_FILE = os.path.expanduser("~/.test_package_scheduler.pid")
scheduler = BackgroundScheduler(daemon=True)

def func():
    print("scheduler running with interval....")

def is_process_running(pid):
    """检查指定PID的进程是否存在"""
    try:
        os.kill(pid, 0)
        return True
    except OSError:
        return False

def daemonize():
    """将进程转为守护进程，脱离终端"""
    # 第一次fork，创建子进程，父进程退出
    try:
        pid = os.fork()
        if pid > 0:
            sys.exit(0)
    except OSError as e:
        click.echo(f"Fork failed: {e}", err=True)
        sys.exit(1)
    
    # 改变工作目录到根目录，避免挂载点被占用
    os.chdir("/")
    # 设置新的会话，脱离原终端控制
    os.setsid()
    # 第二次fork，确保进程不会成为会话首进程，避免再次获取终端
    try:
        pid = os.fork()
        if pid > 0:
            sys.exit(0)
    except OSError as e:
        click.echo(f"Fork failed: {e}", err=True)
        sys.exit(1)
    
    # 重定向标准输入输出到/dev/null，避免占用终端
    sys.stdout.flush()
    sys.stderr.flush()
    with open(os.devnull, 'r') as f:
        os.dup2(f.fileno(), sys.stdin.fileno())
    with open(os.devnull, 'a') as f:
        os.dup2(f.fileno(), sys.stdout.fileno())
        os.dup2(f.fileno(), sys.stderr.fileno())

@click.command()
@click.option('--interval', type=int, default=5, help='Interval for the scheduler in seconds')
def start_scheduler(interval):
    # 检查是否已有运行的进程
    if os.path.exists(PID_FILE):
        with open(PID_FILE, 'r') as f:
            pid = int(f.read().strip())
        if is_process_running(pid):
            click.echo("Scheduler is already running.")
            return
        else:
            # PID文件存在但进程已死，删除旧PID文件
            os.unlink(PID_FILE)
    
    # 转为守护进程
    daemonize()
    
    # 保存当前进程PID到文件
    with open(PID_FILE, 'w') as f:
        f.write(str(os.getpid()))
    
    # 启动调度器
    scheduler.add_job(func, 'interval', seconds=interval)
    scheduler.start()
    
    # 保持主线程运行（BackgroundScheduler的后台线程依赖主线程）
    try:
        while True:
            # 用sleep替代空循环，减少CPU占用
            os.sleep(3600)
    except (KeyboardInterrupt, SystemExit):
        scheduler.shutdown()
        if os.path.exists(PID_FILE):
            os.unlink(PID_FILE)

@click.command()
def stop_scheduler():
    if not os.path.exists(PID_FILE):
        click.echo("Scheduler is not running.")
        return
    
    with open(PID_FILE, 'r') as f:
        pid = int(f.read().strip())
    
    if is_process_running(pid):
        # 发送终止信号，触发进程的清理逻辑
        os.kill(pid, signal.SIGTERM)
        # 等待进程退出后删除PID文件
        while is_process_running(pid):
            os.sleep(0.5)
        os.unlink(PID_FILE)
        click.echo("Scheduler shut down successfully.")
    else:
        os.unlink(PID_FILE)
        click.echo("Scheduler PID file exists but process is not running. Cleaned up PID file.")

@click.command()
def status_scheduler():
    if os.path.exists(PID_FILE):
        with open(PID_FILE, 'r') as f:
            pid = int(f.read().strip())
        if is_process_running(pid):
            click.echo(f"Scheduler is running (PID: {pid}).")
        else:
            click.echo("Scheduler PID file exists but process is not running.")
    else:
        click.echo("Scheduler is not running.")

关键改进说明 #

• 守护进程化：通过两次fork+会话切换，让进程完全脱离终端，执行start后立即返回终端
• PID文件管理：保存后台进程的PID，让stop和status命令可以跨进程识别进程状态
• 优化循环逻辑：用os.sleep(3600)替代空循环，大幅降低CPU占用
• 安全进程检查：通过os.kill(pid, 0)无伤害检查进程是否存活
• 自动清理：进程退出时自动删除PID文件，避免残留无效文件

使用方法 #

1. 重新打包安装：

pip install -e .

2. 启动后台定时任务：

start --interval=3

3. 查看状态：

status

4. 停止任务：

stop

内容的提问来源于stack exchange，提问作者Ratnapal Shende