1.前言
运维平台开发至今，监控模块的主要技术应用也已经非常稳定了，但是随着技术的发展，Python2版本已经逐渐退出舞台，将在2020年失去官方支持，目前最新Python3 Release版本为Python3.7.3，本文章主要描述了再升级Python3.7后celery相关联的修改
2.版本变化
下表为Python2.7下面的依赖库
| 模块 | 版本 | 说明 |
|---|---|---|
| Django | 1.11.5 | |
| django-celery | 3.2.1 | |
| celery | 3.1.25 |
下表为Python3.7环境下的依赖库：
django-celery已经不支持
| 模块 | 版本 | 说明 |
|---|---|---|
| Django | 2.1.7 | |
| django-celery | 3.2.1 | 删除 |
| celery | 4.3.0 | 4.3.0版本才支持Python3.7 |
| django-celery-beat | 1.4.0 |
注意：以前的Celery版本需要一个单独的库（django-celery）才能使用，再Celery3.1之后不要使用django-celery，Django支持开箱即用所以只需要配置就可以应用Celery。
注意：Celery 4.0支持Django 1.8及更高版本。Celery 3.1支持要与Django 1.8的版本
注意：django-celery停止更新
3.配置的变化
3.1 安装django-celery-beat
pip install django-celery-beat
# INSTALLED_APPS添加
INSTALLED_APPS=[
...,
'django_celery_beat',
]
更新数据库
python manage.py makemigrations django_celery_beat
python manage.py migrate django_celery_beat
3.2 Django Settings
TIME_ZONE = 'Asia/Shanghai'
USE_TZ = False
USE_I18N = True
USE_L10N = True
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers.DatabaseScheduler'
BROKER_URL = 'amqp://aegis:nji9VFR$@172.17.118.207:5672//'
CELERY_BROKER_URL = 'amqp://aegis:nji9VFR$@172.17.118.207:5672//'
CELERY_RESULT_BACKEND = 'redis://172.17.118.207:6379/5'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_ENABLE_UTC = False
CELERY_TIMEZONE = 'Asia/Shanghai'
DJANGO_CELERY_BEAT_TZ_AWARE = False
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
3.3 prj中的celery.py
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.utils import timezone
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'aegis.settings')
app = Celery('prj')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.now = timezone.now
# Load task modules from all registered Django app configs.
app.autodiscover_tasks()
3.4 注意事项
再配置完成后运行celery会出现瞬间发起大量任务的问题，查询后原因为禁用了UTC时区时间，导致开始时间异常，细节没有深入研究，有问题可以指出，问题参考：
[2017-12-22 20:07:46,076: DEBUG/MainProcess] db.tasks.send_daily_report sent. id->bdb547f4-9a5c-4208-a976-08f297b16db9
[2017-12-22 20:07:46,078: INFO/MainProcess] Scheduler: Sending due task Send daily report of Oil Changes (db.tasks.send_daily_report)
[2017-12-22 20:07:46,079: DEBUG/MainProcess] db.tasks.send_daily_report sent. id->cd24ccdd-cec8-459d-98a2-e69e68520e6a
[2017-12-22 20:07:46,082: INFO/MainProcess] Scheduler: Sending due task Send daily report of Oil Changes (db.tasks.send_daily_report)
[2017-12-22 20:07:46,084: DEBUG/MainProcess] db.tasks.send_daily_report sent. id->de678d9a-9346-48a5-9528-e4ed61763bff
[2017-12-22 20:07:46,086: INFO/MainProcess] Scheduler: Sending due task Send daily report of Oil Changes (db.tasks.send_daily_report)
[2017-12-22 20:07:46,087: DEBUG/MainProcess] db.tasks.send_daily_report sent. id->f07bee5e-
所以需要修改的地方
3.4.1 settings
TIME_ZONE = 'Asia/Shanghai'
#TIME_ZONE= 'UTC'
USE_TZ = False
USE_I18N = True
USE_L10N = True
CELERY_ENABLE_UTC = False
CELERY_TIMEZONE = 'Asia/Shanghai'
DJANGO_CELERY_BEAT_TZ_AWARE = False
3.4.2 prj/celery.py
上文提到的：
app.now = timezone.now
启动命令
新版本中修改了任务，不会自动生效，因此需要更新数据库
from django_celery_beat.models import PeriodicTask, PeriodicTasks
PeriodicTask.objects.all().update(last_run_at=None)
[PeriodicTasks.changed(task) for task in PeriodicTask.objects.all()]
启动
celery -A aegis worker -B -l info
