FlaskCelery_demo
声明:资源链接索引至第三方,平台不作任何存储,仅提供信息检索服务,若有版权问题,请https://help.coders100.com提交工单反馈
FlaskCelery_demo是一个使用Flask和Celery实现的任务接口样例。它通过Flask创建一个简单的Web应用,并使用Celery处理后台任务。用户可以通过RESTful API提交任务,Celery将任务分解为多个子任务,并在后台异步执行。
以下是一个简单的FlaskCelery_demo示例:
1. 安装所需依赖:
2. 创建一个名为`app.py`的文件,内容如下:
3. 运行Flask应用:
4. 启动Celery worker:
5. 访问`http://localhost:5000/`,查看任务列表。
以下是一个简单的FlaskCelery_demo示例:
1. 安装所需依赖:
pip install Flask Celery Flask-RESTful
2. 创建一个名为`app.py`的文件,内容如下:
from flask import Flask, request
from flask_restful import Resource, Api
from flask_celery import Celery
from flask_migrate import Migrate
from flask_sqlalchemy import SQLAlchemy
from werkzeug.exceptions import HTTPException
import os
app = Flask(__name__)
api = Api(app)
migrate = Migrate(app, db=os.getenv('SQLALCHEMY_DATABASE_URI'))
celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
db = SQLAlchemy(app)
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(50), unique=True)
class Task(db.Model):
id = db.Column(db.Integer, primary_key=True)
user_id = db.Column(db.Integer, db.ForeignKey('user.id'))
description = db.Column(db.String(200))
status = db.Column(db.String(10))
@celery.task()
def add_task(description):
task = Task(user_id=1, description=description)
db.session.add(task)
db.session.commit()
return task
@app.route('/', methods=['GET'])
def index():
tasks = Task.query.all()
return {'tasks': [{'id': task.id, 'name': task.name, 'description': task.description, 'status': task.status} for task in tasks]}
if __name__ == '__main__':
app.run(debug=True)
3. 运行Flask应用:
python app.py
4. 启动Celery worker:
celery -A app worker --loglevel=info
5. 访问`http://localhost:5000/`,查看任务列表。
-
mem0
- 2025-06-07 20:56:15访问
- 积分:1
-
mem0
- 2025-06-07 20:55:42访问
- 积分:1
-
dify
- 2025-06-07 20:50:42访问
- 积分:1
-
ComfyUI-SuperBeasts
- 2025-06-07 20:50:01访问
- 积分:1
-
Person_reID_baseline_pytorch
- 2025-06-07 20:46:12访问
- 积分:1
-
YOLOv8TrafficDetect
- 2025-06-07 20:45:39访问
- 积分:1
-
mrt_cmake_modules
- 2025-06-07 20:44:28访问
- 积分:1
-
mrt_cmake_modules
- 2025-06-07 20:43:59访问
- 积分:1
-
webIDE
- 2025-06-07 20:39:49访问
- 积分:1
-
rogsoft
- 2025-06-07 20:37:58访问
- 积分:1
-
travel-anytime
- 2025-06-07 20:33:40访问
- 积分:1
-
python-utils
- 2025-06-07 20:33:10访问
- 积分:1
-
python_Excel_merge_tool
- 2025-06-07 20:32:28访问
- 积分:1
-
MTUAV_RACE
- 2025-06-07 20:31:49访问
- 积分:1
-
ARIMA_predict_C
- 2025-06-07 20:28:43访问
- 积分:1
-
PR_stat
- 2025-06-07 20:28:05访问
- 积分:1
-
ChatOnLan
- 2025-06-07 20:19:10访问
- 积分:1
-
信息科技学科实验室配置
- 2025-06-07 20:18:19访问
- 积分:1
-
DjangoAdmin_Fastapi_NaiveVue
- 2025-06-07 20:15:08访问
- 积分:1
-
DjangoAdmin_Django_NaiveVue
- 2025-06-07 20:14:26访问
- 积分:1
-
read_the_docs
- 2025-06-07 20:10:00访问
- 积分:1
访问申明(访问视为同意此申明)
2.部分网络用户分享TXT文件内容为网盘地址有可能会失效(此类多为视频教程,如发生失效情况【联系客服】自助退回)
3.请多看看评论和内容介绍大数据情况下资源并不能保证每一条都是完美的资源
4.是否访问均为用户自主行为,本站只提供搜索服务不提供技术支持,感谢您的支持