跳转到主要内容

使用0MQ的Uber极简消息总线

项目描述

ZEBU /ˈzeɪbuː/ - Bos primigenius indicus 或 Bos indicus 或 Bos taurus indicus,有时被称为印度牛或驼峰牛,是一种起源于南亚的家牛物种或亚种。zebu的特点是肩上有一个脂肪驼峰,一个大垂唇,有时耳朵向下垂。它们能够很好地忍受高温,并且在热带国家作为纯种zebu和与欧洲牛杂交的牛被养殖,欧洲牛是家牛的另一种主要类型。zebu被用作役牛、奶牛和肉牛,以及用于生产副产品,如皮革和用于燃料的粪便和肥料。1999年,德克萨斯A&M大学的研究人员成功克隆了一只zebu。 https://en.wikipedia.org/wiki/Zebu

我选择了Minibus这个名字,因为我来自法国,而ZEBU依赖于0MQ,我认为“bus”发音为“zebu”可能是一个很酷的名字。当然,我无法抗拒以一头牛来命名这个模块的诱惑。

Ze服务

ZEBU是一个极简主义的uber总线,我出于乐趣而实现它,结果证明它很有用(至少对我来说是这样)。

要运行ZEBU,您需要设置2个环境变量。ZEBU_PUBLISH是发布者连接到的端点。ZEBU_SUBSCRIBE是订阅者连接到的端点。

端点格式为transport://address,其中transport很可能是ipc或tcp。

$ ZEBU_PUBLISH=ipc://publish ZEBU_SUBSCRIBE=ipc://subscribe python -m zebu

Ze模块

ZEBU也是一个模块,您可以从它导入精心制作的辅助工具来定义……

订阅者

>>> from zebu import subscribe
>>> messages = subscribes('a/topic', 'another/topic')
>>> for message in messages:
...     # do something with message

发布者

>>> from zebu import publisher
>>> publish = publisher()
>>> publish('a/topic', 'a message on that topic')

项目详情


下载文件

下载适用于您平台的文件。如果您不确定选择哪个,请了解有关安装包的更多信息。

源代码分发

zebu-2017.5.0.tar.gz (2.8 kB 查看哈希值)

上传时间 源代码

支持者