flask-dramatiq 0.6.0

Flask-Dramatiq将Dramatiq任务队列集成到您的Flask Web应用程序中。

// 功能 //

• 从Flask配置中配置Dramatiq。
• 确保Flask应用对Dramatiq演员可用。
• 将worker命令添加到Flask CLI。
• 启用Flask应用程序工厂。
• 支持多个具有可配置前缀的代理。
• 集成periodiq。 可选。

完整的文档可在flask-dramatiq.readthedocs.io找到。

// 安装和使用 //

Flask-Dramatiq遵循BSD-3-Clause许可证。将flask-dramatiq添加到您的项目中

$ poetry add flask-dramatiq

然后使用Dramatiq对象作为常规Flask扩展

from flask import Flask
from flask_dramatiq import Dramatiq

app = Flask(__name__)
dramatiq = Dramatiq(app)

@dramatiq.actor()
def my_actor():
    ...

@app.route("/")
def myhandler():
    my_actor.send()

Flask-Dramatiq添加了两个配置键

• DRAMATIQ_BROKER，指向类似于dramatiq.brokers.rabbitmq.RabbitmqBroker或dramatiq.brokers.redis.RedisBroker的代理类。
• DRAMATIQ_BROKER_URL作为url关键字参数传递给代理类。

现在运行工作程序以在后台消费消息并执行任务

$ flask worker --processes=1

项目源树中的完整flask应用程序在example.py中可用。

// 信用和支持 //

请随意在Gitlab项目页面上打开一个问题或提出合并请求。欢迎贡献！

该项目基于Bogdanp/flask_dramatiq_example。