-
整體的功能節點關系
查看全部 -
整體的功能節點關系
查看全部 -
celery 處理大量消息的分布式系統:(1)專注于實時處理的異步任務隊列;(2)支持任務調度。
application(task producer)
broker(task queue)
celery beat(task scheduler)
worker(task consumer)
result（數據庫或redis）
a 生產消息至 b 并由 c 調度給 w 消費 完成后 存入r
使用場景
異步任務：耗時任務給celery一步執行。ep:發送短信/郵件、消息推送、音視頻處理
定時任務：crontab。ep:每日數據統計
查看全部 -
這節我就看了。沒跟著做。
查看全部 -
新版命令改了。改成 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分布式系統，實時處理的異步任務隊列，也支持任務調度。
查看全部 -
broker_url?=?'redis://localhost:6379/1' result_backend?=?'redis://localhost:6379/2' timezone?=?'Asia/Shanghai' imports?=?( ????'celery_app.task1', ????'celery_app.task2', )
celery6.0版本以后將廢棄大寫的配置方式，使用小寫的方式進行配置，并且大寫和小寫的方式不能混用，否則會報錯。
查看全部 -
使用djcelery就不用再手動生成celery實例了查看全部
-
進程管理：supervisor
1、Install：pip install supervisor
2、Start：supervisord -c /etc/supervisord.conf
3、Tool：supervisorctl
查看全部 -
權限驗證：
#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
查看全部 -
#pip install django==1.8
查看全部 -
在Django中使用Celery
查看全部 -
使用Celery
1、Worker：celery -A task worker --loglevel=info
2、Beat：Celery -A task beat
3、Help：celery workker --help
查看全部 -
使用場景：
1、異步任務：將耗時任務提交給celery去異步執行，比如發短信/郵件、消息推送、音頻處理等
2、執行定時任務：類似于crontab,比如每日數據統計
查看全部 -
Celery架構圖
查看全部 -
celery worker -A task -l INFO
celery flower --address=0.0.0.0 --port=5555 --broker=xxx --basic_auth=user:password
查看全部 -
celery介紹
查看全部 -
使用flower監控celery
查看全部
舉報