文件名称:redispatcher:Redis代理的Python异步消息传递服务
文件大小:24KB
文件格式:ZIP
更新时间:2024-04-26 06:27:09
Python
重新分配者 redispatcher是一个小型库,可让您指定一组工作池,这些工作池侦听添加到Redis队列中的消息。 这使您可以异步执行长时间运行的后台任务,例如在用户注册后发送欢迎电子邮件。 redispatcher依赖 aioredis发布到Redis队列中,并让您的消费者从Redis中阅读 pydantic验证所有消息并确保它们符合您指定的形状 您应该尝试重新分配 有一个Redis实例 有一个Web服务,需要在后台处理长时间运行的任务 不想处理建立Rabbit和诸如Celery这样繁琐的库的工作 概述 重新分配程序可以分为三个(ish)部分。 消费者 这一切都始于消费者。 使用者只是一个类,它定义了它将要侦听的mssages的结构,并且是一个实现用于处理该消息的逻辑的函数。 出版 您定义的每个使用者都将为您提供一种易于publish方法,您可以使用该方法将消息排队。 因为我们使用P
【文件预览】:
redispatcher-master
----poetry.lock(41KB)
----pyproject.toml(1KB)
----LICENSE(1KB)
----.DS_Store(6KB)
----.env(38B)
----isort.cfg(137B)
----examples()
--------redispatcher_worker.py(975B)
--------basic_consumer.py(923B)
--------__init__.py(0B)
--------nicer_consumer.py(2KB)
--------example_publish.py(1KB)
----redispatcher()
--------models.py(111B)
--------__init__.py(299B)
--------consumer_pool.py(2KB)
--------base_consumer.py(885B)
--------config.py(315B)
----.gitignore(11B)
----README.md(3KB)
----.vscode()
--------settings.json(732B)