taskiq异步分布式任务管理器 适用fastapi

taskiq 异步分布式任务管理器

https://taskiq-python.github.io/
将 taskiq 视为 asyncio celery 实现。它使用几乎相同的模式，但它更加现代和灵活。
它不是任何其他任务管理器的直接替代品。它具有不同的库生态系统和一组不同的功能。此外，它不适用于同步项目。将无法同步发送任务。
1 安装taskiq

1. pip install taskiq

复制代码

2 使用

我这里使用的是fastapi+rabbitmq，所以需要多装一个taskiq-aio-pika包来使用

1. pip install taskiq-aio-pika

复制代码

项目路径如下：

broker.py:

1. from taskiq_aio_pika import AioPikaBroker
3. from app.core.config import settings
5. broker = AioPikaBroker(url="amqp://guest:guest@localhost:5672//") # 此处替换broker_url

复制代码

这里必须要定义一个worker.py，显式的导入你的tasks和broker。不然会报如下错误：

1. task "xxxx" is not found. Maybe you forgot to import it?

复制代码

worker.py:

1. from app.tasks.broker import broker
3. import app.tasks.notify_tasks

复制代码

xxx_tasks.py:

1. from app.tasks.broker import broker
4. @broker.task
5. async def test_tasks():
6.         # 现在就可以支持async await使用 例如：
7.         async with httpx.AsyncClient() as client:
8.                 await client.post("jd.com", json=body)
9.         return

复制代码

3 cli启动命令：

1. taskiq worker app.tasks.worker:broker

复制代码

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

这个有用。

感谢分享

喜欢鼓捣这些软件，现在用得少，谢谢分享！

热心回复！

东西不错很实用谢谢分享

不错，里面软件多更新就更好了

这个有用。

谢谢楼主提供！

谢谢分享，试用一下

前排留名，哈哈哈

感谢分享，学习下。

感谢，下载保存了

热心回复！

不错，里面软件多更新就更好了

收藏一下   不知道什么时候能用到

鼓励转贴优秀软件安全工具和文档！

这个好，看起来很实用

感谢分享，下载保存了，貌似很强大

这个有用。