-
broker_url = 'redis://localhost:6379/1' result_backend = 'redis://localhost:6379/2' timezone = 'Asia/Shanghai' imports = ( 'celery_app.task1', 'celery_app.task2', )
celery6.0版本以后将废弃大写的配置方式，使用小写的方式进行配置，并且大写和小写的方式不能混用，否则会报错。
查看全部 -
进程管理：supervisor
1、Install：pip install supervisor
2、Start：supervisord -c /etc/supervisord.conf
3、Tool：supervisorctl
查看全部 -
# celery 配置 # 有些情况下防止死锁 CELERYD_FORCE_EXECV = True # 设置并发的worker数量 CELERYD_CONCURRENCY = 4 # 允许重试 CELERY_ACKS_LATE = True # 每个worker最多允许执行100个任务被销毁，可以防止内存泄漏 CELERY_MAX_TASKS_PER_CHILD = 100 # 单个任务的最大运行时间 CELERYD_TASK_TIME_LIMIT = 12 * 30
查看全部 -
这节我就看了。没跟着做。
查看全部 -
新版命令改了。改成 celery --broker='redis://xxxx:6379' flower
查看全部 -
新版的不再是 from celery.task import Task
而是from celery import Task
另外URLpatterb的写法也不一样，9:11在讲URL
下面这个总结里的我就没用上。因为djcelery在新版celery中不支持。旧版celery又装不上。
我最后还是使用了前一个章节的
@app.task
def dj_cron_task():这种形式去完成了本节内容。
查看全部 -
celery 5的版本的cli写法有点不一样。要留意。
查看全部 -
本课demo使用redis做消息队列。安装的话就要:
pip install celery[redis]
这节前半节在demo virtualenv, pyenv这些venv的使用
查看全部 -
安装：pip install celery[redis]
消息中间件：RabbitMQ/Redis(用redis比RabbitMQ方便)
创建虚拟环境：（1）安装pip install virtualenv
创建：virtualenv env4test
激活：source env4test/bin/activate
退出虚拟环境：deactivate
（2）安装pip install virtualenvwrapper
改配置：一般在目录ls /usr/local/bin/virtualenvwrapper.sh
vi ~/.zshrc中新增
添加完成立即生效：source ~/.zshrc
创建：mkvirtualenv env4test
退出虚拟环境：deactivate
激活：workon env4test
workon 列出所有虚拟环境
pyenv通过系统改坏境变量，改变python变量
查看全部 -
celery分布式系统，实时处理的异步任务队列，也支持任务调度。
查看全部 -
权限验证：
#python manage.py celery flower --basic_auth=imooc:imooc
查看全部 -
监控工具：flower
查看全部 -
监控工具：flower
Install : pip install flower
查看全部 -
在Django中使用celery
1、install：pip install django-celery
2、Worker：python manage.py celery worker -Q queue
3、Beat：python manage.py celery beat
查看全部 -
创建项目
#django-admin.py startproject imooc
查看全部
举报