Python3.7环境中celery 在django中的应用

1.前言

运维平台开发至今，监控模块的主要技术应用也已经非常稳定了，但是随着技术的发展，Python2版本已经逐渐退出舞台，将在2020年失去官方支持，目前最新Python3 Release版本为Python3.7.3，本文章主要描述了再升级Python3.7后celery相关联的修改

2.版本变化

下表为Python2.7下面的依赖库

下表为Python3.7环境下的依赖库：
django-celery已经不支持

注意：以前的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时区时间，导致开始时间异常，细节没有深入研究，有问题可以指出，问题参考：

GitHub issues 109

[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