cenphoenix

支持，干的漂亮

怎么现在貌似动不动就说要上微服务，真有那么大的访问量用得上微服务吗。

```
@shared_task
def xsum(numbers):
return sum(numbers)
```

@yuhuang 你在 task 里面调用 Group 进行通知不行吗？象这样

@celery_app.task
def send_phone_code(user_id, verify_token, phone_number):
customer = Customer.objects.get(id=user_id)
#发送短信操作
send_message(...)
try:
# 通知任务已完成
Group('phone_verify-%s' % customer.username).send({
'text': json.dumps({
'success': True,
'msg': 'new message sent'
})
})
except Exception as e:
# 通知任务失败
Group('phone_verify-%s' % customer.username).send({
'text': json.dumps({
'success': False,
'msg': e.msg
})
})

用 Group 是否可行？用户登录进来的时候根据用户 id 创建只有他的 Group 里，异步完成后也是根据这个 id 用 Group 进行通知

不错