一个微服务纳米框架。
项目描述
🐎 斜坡式
一个花哨且具有偏见的微服务纳米框架。
安装
pip install rampante
如何使用 subscribe_on
from rampante import subscribe_on
# The function should accept 3 params
# queue_name, for example could be "user.subscribed"
# data is a dictionary, it's a msgpacked message sent to NATS
# app, aiohttp app instance (in case)
@subscribe_on("user.subscribed")
async def send_a_message(queue_name, data, app):
log.info("Event received!")
@subscribe_on("user.subscribed", "user.created")
async def send_another_message(queue_name, data, app):
log.info("Event received!")
示例
查看文件夹内的示例!
您需要一个运行的nats-streaming:0.6.0,请检查Makefile :)
名称
斜坡式在意大利语中的意思是“狂暴”。
为什么选择NATS?
它用Go编写,看起来工作得很好!
待办事项
添加任务失败时的重试/逻辑
鼓励提交拉取请求!
许可证
Apache 2.0
项目详情
关闭
rampante-0.0.14.tar.gz 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 5775ea51d4f872601d0f4e73400d2614b63b179c8d554babf218c4b9a19b43ca |
|
MD5 | d712ee2c9cf94d3ed637dd6e594161c8 |
|
BLAKE2b-256 | 01a3a9dd97f3e8a6abd3d0e5f9f8314688d6e5ca73dd6df350101c4ad546ef8c |
关闭
rampante-0.0.14-py2.py3-none-any.whl 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | d6334e3298c2c8707b6ad19eb0a5ba7532d55a0f8b58927bfa66201f18e2bc36 |
|
MD5 | 89ef6a9e60e19e26a5cc82bc5c2f551a |
|
BLAKE2b-256 | 482c72d8bd6312ead10f435586867b5f7a1be3f6ec807f3ce2b290743733b84f |