这种方法缺陷也很明显，就是每分钟都需要启动一次定时任务，看起来很呆。比较浪费资源，苍蝇再小也是肉哇。 但是对于我当前的项目来说这个需求是非常重要的。浪费点资源也是值得的。
最后，希望有更好解决方案的童鞋或者前辈能够给指点一下。
由于公司项目的需求，有时候需要更改系统时间，当把系统时间从当前（T1）往未来时间（T2）调整的话没什么问题，但是再从未来时间（T2）往回调整就会造成定时任务挂起的情况。网上也找了很多资料，但是没有什么合适的解决方案，很多文章提供的解决方案就是→重启项目！！！（我竟无言以对）。然后呢，就自己想了个解决方案，当然只是完成了需求，在性能方面其实不好。希望有更好解决方案的前辈留言指点一下。定时任务大概...
在 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 的存储方式改为数据库存储，解决服务重启后
定时任务失效的
问题。
