这一个非常精简的组合, 但是功能实现了, 目的是为了理解. 后续会在一步一步的优化和改进.
操作环境
系统: CentOS7.4
- Python:3.6.8
- celery:4.2.1
- Flask:1.0.2
1. Redis 操作
安装 Redis, 启动服务, 测试是否成功
- [root@python-server01 ~]# yum install Redis
- [root@python-server01 ~]# systemctl start Redis
- [root@python-server01 ~]# Redis-cli
- 127.0.0.1:6379> ping
- PONG
- 127.0.0.1:6379>
2. Python 操作
确保编译安装 Python 之前安装了 bzip2-devel. 如果没有, 需要再安装 bzip2-devel 后重新编译安装一次 Python. 否则会出现报错: ModuleNotFoundError: No module named '_bz2'.
yum install bzip2-devel
在 Python 环境下安装 Flask,celery
- pip install flask
- pip install celery
3. Flask 程序操作
主程序内容如下
- import time
- from flask import Flask
- from celery import Celery
- flask_app = Flask(__name__)
- flask_app.config['CELERY_BROKER_URL'] = 'redis://127.0.0.1:6379/0'
- celery = Celery(flask_app.name, broker=flask_app.config['CELERY_BROKER_URL'])
- @celery.task()
- def add_together(a, b):
- time.sleep(60)
- return a + b
- @flask_app.route('/')
- def hello_world():
- with flask_app.app_context():
- result = add_together.delay(23, 42)
- return 'Hello World!'
- if __name__ == '__main__':
- flask_app.run(host='192.168.17.128', port=80)
4. 启动操作
先启动 celery, 监听任务消息.(App.celery:App 是 App.py,celery 是 App.py 里面的 Celery 实例)
- (venv3_test01) [root@python-server01 flask01]# ls
- App.py __pycache__ static task.py templates
- (venv3_test01) [root@python-server01 flask01]# celery -A App.celery worker --loglevel=info
当启动之后, 有任务在后台工作时, 会看到类似日志:
- [2019-03-04 02:59:38,007: INFO/MainProcess] celery@python-server01.localdomain ready.
- [2019-03-04 02:59:59,943: INFO/MainProcess] Received task: App.add_together[0c803786-cbe8-41b8-87b5-40d1d441559d]
- [2019-03-04 03:01:00,010: INFO/ForkPoolWorker-1] Task App.add_together[0c803786-cbe8-41b8-87b5-40d1d441559d] succeeded in 60.06519331100026s: 65
然后启动 web 程序, 访问测试, 可以立即看到 "Hello World!" 字样, 无需等待 60 秒. Web 日志如下:
- * Running on http://192.168.17.128:80/ (Press CTRL+C to quit)
- 975efddd-4e58-4414-b0fb-66613dcf1c5e
- 192.168.17.1 - - [04/Mar/2019 03:09:11] "GET / HTTP/1.1" 200 -
- ee875a60-22a0-42cb-a8f5-37f11dcf6cba
- 192.168.17.1 - - [04/Mar/2019 03:09:29] "GET / HTTP/1.1" 200 -
- 17e4157a-c8e4-480e-8d22-ff125d2d4795
- 192.168.17.1 - - [04/Mar/2019 03:09:30] "GET / HTTP/1.1" 200 -
来源: http://www.jianshu.com/p/523a72c86ccf