【文件属性】:
文件名称:redispatcher:Redis代理的Python异步消息传递服务
文件大小:24KB
文件格式:ZIP
更新时间:2021-04-06 12:40:29
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)