前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Django 2.1.7 Celery 4.3.0 配置

Django 2.1.7 Celery 4.3.0 配置

作者头像
Devops海洋的渔夫
发布2019-08-06 17:36:13
7090
发布2019-08-06 17:36:13
举报
文章被收录于专栏:Devops专栏Devops专栏

本篇章来看看关于配置这块的内容。

配置

Celery使用简单,配置也非常简单。Celery有很多配置选项能够使得celery能够符合我们的需要,但是默认的几项配置已经足够应付大多数应用场景了。

配置信息可以直接在app中设置,或者通过专有的配置模块来配置。

1.直接通过app来配置

代码语言:javascript
复制
from celery import Celery

app = Celery(
    'celery_tasks.tasks',
    broker='redis://127.0.0.1:6379/8',
    backend='redis://127.0.0.1:6379/9',
)

还可以这样写,如下:

代码语言:javascript
复制
from celery import Celery

app = Celery('celery_tasks.tasks')

# 增加配置
app.conf.update(
    result_backend='redis://127.0.0.1:6379/9', 
    broker_url='redis://127.0.0.1:6379/8',
)

使用app.conf.update的方法更新配置的指定参数与前面的有些不一样。例如:前面写broker='redis://127.0.0.1:6379/8',,后面的配置写成broker_url='redis://127.0.0.1:6379/8',

2.专有配置文件

对于比较大的项目,我们建议配置信息作为一个单独的模块。我们可以通过调用app的函数来告诉Celery使用我们的配置模块。

配置模块的名字我们取名为celeryconfig, 这个名字不是固定的,我们可以任意取名,建议这么做。我们必须保证配置模块能够被导入。

下面我们在tasks.py模块 同级目录下创建配置模块celeryconfig.py:

代码语言:javascript
复制
# 设置结果存储
result_backend='redis://127.0.0.1:6379/9'

# 设置代理人broker
broker_url='redis://127.0.0.1:6379/8'

tasks.py文件修改为:

代码语言:javascript
复制
from celery import Celery
from . import celeryconfig # 导入配置文件

app = Celery('celery_tasks.tasks')

# 从单独的配置模块中加载配置
app.config_from_object(celeryconfig)

更多配置: http://docs.celeryproject.org/en/latest/userguide/configuration.html#configuration

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019.08.03 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 配置
    • 1.直接通过app来配置
      • 2.专有配置文件
      相关产品与服务
      云数据库 Redis
      腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档