首页 小编推荐正文

周记怎么写,Python 守时使命 Celery + Redis + Flower + Supervisor,元朝

一Redis for Mac

Client 下载

http://www.pc6.com/mac/486661.ht周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝ml 

装置

br性感受ew install redis 

发动

redis-周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝server /usr/local/etc/redis.conf 

封闭

redis-cli shutdown 

检测服务器是否发动

redis-cli ping 

二Celery

装置

pip install celery[redis] 

简易Demo

import time
from celery import Celery
# 音讯中间件 Broker
broker = 'redis://localhost:6379/1'
# 任务成果存储 Backend
backend = 're女性直播dis://localhost:6379/2'
myCelery = Celery('my_task', broker=broker, backend=backend)
@myCelery.task
def add(x, y):
print('enter call func ...')
time.sleep(5)
return x, y

运转 tasks Worker

celery worker -A tasks -l INFO 

外部装备

BROKER_URL = 'redis://localhost:6379/1'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/2'
CELERY_TIMEZONE = 'Asia装甲狙击手/Shanghai'
CELERY_IMPORTS = (
'celery_app.task1',
'celery_app.t周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝ask2'唐一白是谁演的,
)

初始化Celery

fraotm奥特曼动画片om celery import Celery
app = Celery('celery_app')
app.config_from_object('celery_app.celeryconfig')

运转 celery_app Worker

celery worker -A celery_app农门药香神医贵女 -l INFO 

调用任务

# 你可以用 delay() 方法来调用任务。
from tasks import add
add.delay(4, 4)
# 检查是否完结
result.ready()
# 获取成果
result.get(timeout=1)

Redis存储的成果信息

eg:
{"statu周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝s": "SUCCESS", "result": 6, "traceback": null, "children": [], "task_id": "423d645d-86d9-4c91-a0e8-82a1ab997147", "date_done": "2019-08-17T1陈不时4:54:43.189881"}

装备守时任务

CELERYBEAT_SCHEDULE = {
'task1': {
汇包网'task': 'celery_app.task1.add',
'schedule': timedelta(seconds=10),
'args': (2, 8)
},
'task2': {
'task': 'celery_app.task2.multiply',
'schedule': cront周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝ab(hour=23, minute=15),
'args': (4, 音乐问候称为什么5)
}
}

发送守时任务

celery beat -A celery_app -l INFO
# 或
celery worker -A celery_app -l INFO -B

三Flower 监控任务

安周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝装

pip install flower 

发动

celery flower --broker=redis://localhost:63罗西贝微博79/1 --address=127.0.0.1 --port=9999 --basic_auth=admin:123456 

四Supervisor 进程办理

装置

pip install supervisor 

添加装备一

mkdir conf
echo_supervisord_conf > conf/supervisord.c白鹿原床戏onf

添加装备二

[program:demo-celery-worker]
command=celery worker -A celery_app -l INFO -B
directory=/celery_app
environment=PATH=梁君诺虚浮"/celery_app/venv/bin"
stdo陶燕青ut_secsetupwizard已中止logfile=/celerwoeboty_app/logbtkszx/work.log
stderr_logfile=/celery_app/log/err.lo张嫣为什么称艳后g
autostart=true

发动进程 for mac

supervisord -c conf/supervisord.conf
ps -ef|grep supervisor

检查进程

#进入命令行形式
supervisor弟弟妹妹ctl
#更新进程组
upda女性咪咪te
# 进程状况
demo-celery-worker RUNNING pid 12711, uptime 0:02:26

WE周记怎样写,Python 守时任务 Celery + Redis + Flower + Supervisor,元朝B展现

http://127.0.0.1:9001/ 

点重视不走失勺子带你学技能!哈哈!

版权声明

本文仅代表作者观点,不代表本站立场。
本文系作者授权发表,未经许可,不得转载。