使用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 的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | dd22412d6b3f8a57ec48e1529278c3563043fed491b92d374bc88eba372ea4b4 |
|
MD5 | 46ef3177f2c71e15a16941da6e66ff6c |
|
BLAKE2b-256 | f2a2a5047b2d5c306838aaf27af9e3274ddf11daa076d08bd0d6f366836a53b2 |