如何定期运行带参数的函数？Django结合APScheduler实现用户自定义周期任务

核心逻辑修正 #

你之前的思路问题在于：Django启动时执行的apps.py的ready方法不存在请求上下文，本身就不可能拿到request.user。定时任务不需要依赖请求上下文，每次运行时直接从数据库读取所有用户的DashboardData配置即可，既解耦又支持用户动态修改配置无需重启服务。

小提醒：你原来的forms.py里period字段定义末尾多了一个多余的右括号，记得先删掉避免语法错误。

步骤1：编写通用调度执行函数 #

修改functions.py，新增统一的任务入口，按周期拉取所有对应用户的配置执行：

from datetime import datetime
from .models import DashboardData

# 修正原myFunction里的变量拼写错误
class myFunction():
    def __init__(self, n_user, n_password):
        self.time = datetime.now().strftime("%Y-%m-%d")
        self.location = a_url # 替换为实际的url变量
        self.static_fields = {}
        self.index_name = "pre-" + self.time 
        self.download_all(n_user, n_password)
        self.send_it()

# 新增按周期执行的通用任务
def run_periodic_task(period_hours):
    # 拉取所有选择对应周期的用户配置
    all_configs = DashboardData.objects.filter(period=str(period_hours)).all()
    for config in all_configs:
        # 传入用户填写的用户名密码执行
        myFunction(config.n_username, config.n_password)

步骤2：初始化APScheduler #

在你的dashboard应用下新建scheduler.py：

from apscheduler.schedulers.background import BackgroundScheduler
from .functions import run_periodic_task

scheduler = BackgroundScheduler(timezone='Asia/Shanghai') # 替换为你所在的时区

def start_scheduler():
    # 每周执行：168小时
    scheduler.add_job(run_periodic_task, 'interval', hours=168, args=(168,), id='weekly_task')
    # 每月执行：720小时
    scheduler.add_job(run_periodic_task, 'interval', hours=720, args=(720,), id='monthly_task')
    # 每年执行：8766小时
    scheduler.add_job(run_periodic_task, 'interval', hours=8766, args=(8766,), id='yearly_task')
    scheduler.start()

步骤3：修正apps.py启动逻辑，避免重复启动 #

Django开发模式下runserver默认启动两个进程，会导致调度器初始化两次，需要加判断过滤：

import os
from django.apps import AppConfig

class DashboardConfig(AppConfig):
    default_auto_field = 'django.db.models.BigAutoField'
    name = 'dashboard'
    def ready(self):
        # 只在主进程、且是启动服务的场景下启动调度器
        if os.environ.get('RUN_MAIN') == 'true' and 'runserver' in sys.argv:
            from .scheduler import start_scheduler
            start_scheduler()

步骤4：视图层保存表单时关联当前用户 #

在提交表单的视图逻辑里，保存实例的时候手动赋值user字段即可，示例：

from django.contrib.auth.decorators import login_required
from .forms import SetupForm

@login_required
def setup_view(request):
    if request.method == 'POST':
        form = SetupForm(request.POST)
        if form.is_valid():
            config = form.save(commit=False)
            config.user = request.user # 关联当前登录用户
            config.save()
            # 后续跳转逻辑自行补充
    else:
        form = SetupForm()
    return render(request, 'setup.html', {'form': form})

额外优化建议 #

• 当前DashboardData是明文存储密码，存在安全风险，建议使用cryptography库加密存储，调用函数前再解密
• 如果要支持用户删除配置后停止对应任务，不需要额外处理，因为任务执行时会实时拉取最新的数据库记录，已删除的配置不会被加载
• 可以给任务加运行日志，方便排查执行失败的问题

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