celery的基本使用

关于celery：https://www.celerycn.io/

因为celery是可以单独运行的，所以我们放在任何位置都行

我们创建一个tasks的文件夹再lghome（为了方便观看美观），再在其中创建一个task_sms.py的文件

使用celery包含三个方面：1，定义任务函数  2，运行celery服务   3，客户应用程序的调用

现在我们就定义完了celery

我们如何掉用呢

    from lghome.tasks.task_sms import send_sms
    send_sms.delay(mobile,(sms_code,int(constans.SMS_CODE_REDIS_EXPIRES/60)),1)

注意方法后面一定要有delay（）这样才会异步运行

现在我们没有返回值了，所以修改代码，直接返回发送成功

我们的celery也是需要手动启动的

celery -A home.tasks.task_sms worker -l info

• -A指对应的应用程序, 其参数是项目中 Celery实例的位置。
• worker指这里要启动的worker。
• -l指日志等级，比如info等级。

windows中可能需要这样启动，加一个-P

celery -A lghome.tasks.task_sms worker -l info -P eventlet

 

这样就是启动成功了，进入到注册页面，我们发送给短信，再看终端

statusCode：000000发送成功，如果有错误会在celery中报错