django中使用apscheduler实现定时任务，服务重启后定时任务失效怎么解决

在 Django 中使用 Apscheduler 实现定时任务时，服务重启后定时任务会失效的原因是因为 Apscheduler 的默认存储方式是内存存储，当服务重启后，内存中的数据会被清空，导致定时任务信息丢失。

为了解决这个问题，可以将 Apscheduler 的存储方式改为数据库存储。具体实现步骤如下：

1. 首先安装 Apscheduler 和 Django 的数据库驱动，比如 psycopg2 或者 mysqlclient。

2. 在 Django 项目的 settings.py 文件中配置数据库信息：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.postgresql',
        'NAME': 'your_db_name',
        'USER': 'your_db_user',
        'PASSWORD': 'your_db_password',
        'HOST': 'localhost',
        'PORT': '5432',
    }
}

3. 在 Django 项目的 settings.py 文件中添加 Apscheduler 的配置信息：

SCHEDULER_JOBSTORES = {
    'default': SQLAlchemyJobStore(url='postgresql://your_db_user:your_db_password@localhost/your_db_name')
}

SCHEDULER_EXECUTORS = {
    'default': {'type': 'threadpool', 'max_workers': 20}
}

SCHEDULER_JOB_DEFAULTS = {
    'coalesce': False,
    'max_instances': 3
}

SCHEDULER_API_ENABLED = True

其中，`url` 参数的格式为：`<database>://<user>:<password>@<host>/<database_name>`，根据自己的数据库信息进行修改。

4. 在 Django 项目的 urls.py 文件中注册 Apscheduler 的 API：

from apscheduler.scheduler import Scheduler
from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
from django_apscheduler.jobstores import DjangoJobStore
from django_apscheduler import util

scheduler = Scheduler(
    jobstores={
        'default': DjangoJobStore(),
        'sqlalchemy': SQLAlchemyJobStore(url='postgresql://your_db_user:your_db_password@localhost/your_db_name')
    },
    executors={
        'default': {'type': 'threadpool', 'max_workers': 20}
    },
    job_defaults={
        'coalesce': False,
        'max_instances': 3
    },
    timezone=util.get_timezone('Asia/Shanghai')
)

# 添加定时任务
def test_job():
    print("test job")

scheduler.add_job(test_job, 'interval', seconds=10)

# 启动定时任务
scheduler.start()

# 注册 API
from django.urls import path
from django_apscheduler.views import DjangoJobView, DjangoJobAllView, DjangoJobRunView

urlpatterns = [
    path('admin/', admin.site.urls),
    path('jobs/', DjangoJobView.as_view()),
    path('jobs/all/', DjangoJobAllView.as_view()),
    path('jobs/run/<job_id>/', DjangoJobRunView.as_view()),
]

其中，`scheduler.add_job()` 函数用于添加定时任务，这里添加了一个每隔 10 秒执行一次的测试任务。

5. 在 Django 项目的 wsgi.py 或者 asgi.py 文件中启动 Apscheduler：

import os
from django.core.wsgi import get_wsgi_application
from apscheduler.schedulers.background import BackgroundScheduler

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')

application = get_wsgi_application()

scheduler = BackgroundScheduler()
scheduler.add_jobstore('django', 'default')
scheduler.start()

在这里，使用 BackgroundScheduler 启动 Apscheduler，并将默认的 jobstore 设置为 django，即使用 DjangoJobStore 存储定时任务信息。

通过以上步骤，就可以将 Apscheduler 的存储方式改为数据库存储，解决服务重启后定时任务失效的问题。