版本信息
|
1
2
3
4
5
6
7
8
9
|
# 插件安装 Django==2.2.2django-celery-beat==2.1.0django-redis==4.8.0mysqlclient==2.0.0django-mysql==3.2.0redis==3.2.1uWSGI==2.0.17.1django-redis-cache==2.1.0 |
安装与配置
- 安装上面的对应的celery版本
- 配置settings.py
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
# django时区配置TIME_ZONE = 'Asia/Shanghai'# 如果USE_TZ设置为True时，Django会使用系统默认设置的时区，此时的TIME_ZONE不管有没有设置都不起作用# 如果USE_TZ 设置为False,TIME_ZONE = 'Asia/Shanghai', 则使用上海的UTC时间。USE_TZ = FalseINSTALLED_APPS = ( ..., 'django_celery_beat',)# celery beat配置# CELERY_ENABLE_UTC = FalseCELERY_TIMEZONE = TIME_ZONEDJANGO_CELERY_BEAT_TZ_AWARE = FalseCELERY_BEAT_SCHEDULER = 'django-celery-beat.schedulers.DatabaseScheduler'# celery 的启动工作数量设置CELERY_WORKER_CONCURRENCY = 10# 任务预取功能，会尽量多拿 n 个，以保证获取的通讯成本可以压缩。CELERYD_PREFETCH_MULTIPLIER = 20# 有些情况下可以防止死锁CELERYD_FORCE_EXECV = True# celery 的 worker 执行多少个任务后进行重启操作CELERY_WORKER_MAX_TASKS_PER_CHILD = 100# 禁用所有速度限制，如果网络资源有限，不建议开足马力。CELERY_DISABLE_RATE_LIMITS = True# 设置代理人brokerCELERY_BROKER_URL = 'redis://127.0.0.1:6379/2'# 指定 BackendCELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/1' |
生成数据库
python manage.py migrate
|
1
2
3
4
5
|
# 迁移之后生成的表结构django_celery_beat.models.PeriodicTask 此模型定义要运行的单个周期性任务。django_celery_beat.models.IntervalSchedule 以特定间隔（例如，每5秒）运行的计划。django_celery_beat.models.CrontabSchedule 与像在cron项领域的时间表 分钟小时日的一周 DAY_OF_MONTH month_of_yeardjango_celery_beat.models.PeriodicTasks 此模型仅用作索引以跟踪计划何时更改 |
在工作目录下配置celery.py
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
# -*- coding: utf-8 -*-# @File: celeryc.py# @Content: celery定时任务配置import osfrom celery import Celery, platformsfrom celery.schedules import crontabfrom django.conf import settingsos.environ.setdefault("DJANGO_SETTINGS_MODULE", "django_server.settings")app = Celery("django_server")app.config_from_object("django.conf:settings", namespace="CELERY")# 定时任务的存放位置app.autodiscover_tasks(["monitoring.tasks", "wechat.tasks"]) |
创建tasks任务
|
1
2
3
4
5
|
from celery import shared_task@shared_taskdef alarm_monitor_task(**kwargs): print("定时任务！！！") |
创建定时任务
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
from django_celery_beat.models import PeriodicTask, IntervalSchedule-----周期性任务# 创建10分钟的间隔 interval 对象schedule, _ = IntervalSchedule.objects.update_or_create(every=10, period=IntervalSchedule.MINUTES)# 如果任务存在就更新，不存在则创建PeriodicTask.objects.update_or_create( defaults={ "interval": schedule, # 上面创建10分钟的间隔 interval 对象 "task": "monitoring.tasks.alarm_monitor_task", # 指定需要周期性执行的任务 "args"=json.dumps(['arg1', 'arg2']), "kwargs": json.dumps({"a": 1, "b": 2}, ensure_ascii=False) # 传入的参数 }, name="定时任务-task",)# 周期性任务可选参数IntervalSchedule.DAYS 固定间隔天数IntervalSchedule.HOURS 固定间隔小时数IntervalSchedule.MINUTES 固定间隔分钟数IntervalSchedule.SECONDS 固定间隔秒数IntervalSchedule.MICROSECONDS 固定间隔微秒----Crontab 周期性任务from django_celery_beat.models import CrontabSchedule, PeriodicTask# 创建间隔30分钟执行的任务crontab, _ = CrontabSchedule.objects.update_or_create( minute="*/30", hour="*", day_of_week="*", day_of_month='*', month_of_year='*', timezone=pytz.timezone("Asia/Shanghai"),)# 任务存在则更新，不存在创建PeriodicTask.objects.update_or_create( name=task_name, defaults={ "kwargs": json.dumps(kwargs, ensure_ascii=False), "task": "wechat.tasks.subscribe_task", "crontab": crontab, },)# 删除任务task = PeriodicTask.objects.filter(name__startswith=sub_id)if task: task.update(enabled=False) task.delete() # 暂停当前任务tasks = PeriodicTask.objects.filter(name__startswith=sub_id)if tasks: tasks.update(enabled=True if status else False) |
运行任务
|
1
2
3
4
5
|
# 启动任务 workcelery -A django_server worker -l INFO --logfile=/var/log/dec_server/worker.log# 启动定时器触发 beatcelery -A django_server beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler --logfile=/var/log/dec_server/beat.log |
Tips:
参考链接：
https://github.com/celery/django-celery-beat
https://pypi.org/project/django-celery-beat/
到此这篇关于Django使用 django-celery-beat动态添加定时任务的文章就介绍到这了,更多相关django celery beat动态添加定时任务内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/qq_39248703/article/details/120899843
