5. 任务状...
发布时间
阅读量：
阅读量
Celery具备追踪任务状态变化的能力，可通过配置on_message回调函数实现。随后，我编写了如下代码并启动测试过程：
import time
from celery import Celery
from celery import states
app = Celery('tasks',
backend='amqp://agent:agent@172.18.231.134:5672',
broker='amqp://agent:agent@172.18.231.134:5672')
@app.task(bind=True)
def track_states(self, x, y):
time.sleep(5)
self.update_state(state='PROGRESS', meta={'progress': 50})
time.sleep(5)
self.update_state(state='PROGRESS', meta={'progress': 80})
全部评论 (0)
还没有任何评论哟~