pyhermes

Python接口到Hermes消息代理。

文档

完整文档位于https://pyhermes.readthedocs.org。

安装

要安装pyhermes，只需

pip install pyhermes

然后在项目中使用它

import pyhermes

功能

• 待办事项

快速入门

订阅者

要为特定订阅主题创建处理器，请使用 subscribe 装饰器装饰你的函数

import pyhermes

@pyhermes.subscriber(topic='pl.allegro.pyhermes.sample-topic')
def handler(data):
    # process data

每次有新消息发布到所选主题时，都会调用此函数。

发布者

使用 publish 函数将数据发布到 hermes 的某个主题

import pyhermes

@pyhermes.publisher(topic='pl.allegro.pyhermes.sample-topic')
def my_complex_function(a, b, c):
    result = a + b + c
    publish(my_complex_function._topic, {'complex_result': result})

你也可以直接发布函数的结果

import pyhermes

@pyhermes.publisher(topic='pl.allegro.pyhermes.sample-topic', auto_publish_result=True)
def my_complex_function(a, b, c):
    return {'complex_result': a + b + c}

装饰函数的结果将自动发布到 hermes 的所选主题。

运行测试

代码真的工作吗？

source <YOURVIRTUALENV>/bin/activate
(myenv) $ pip install -r requirements/test.txt
(myenv) $ python runtests.py

致谢

用于渲染此包的工具

• Cookiecutter
• cookiecutter-djangopackage

历史

0.6.0 (2023-13-02)

• Django 4.1 兼容性

0.5.0 (2022-09-02)

• 将 django 应用标签重命名为 pyhermes.django 到 pyhermes_django
• Django 3.2 兼容性

0.3.0 (2016-12-29)

• 在失败的情况下重试发布到 hermes（默认：3 次）
• 支持 Python3.6、Django 1.10 和 Django 开发版本在测试中

0.2.1 (2016-12-12)

• 为 django 应用 #11 配置自定义标签

0.2.0 (2016-11-03)

• 解决 pyhermes.decorators.subscriber 的歧义（将订阅器模块重命名为 subscription）

0.1.3 (2016-06-21)

• 允许在订阅器函数周围使用自定义包装器
• 为事件 ID 和重试次数添加额外的日志记录
• 添加对 Django <= 1.7 的支持
• 原始数据仅记录到调试日志。

0.1.2 (2016-04-20)

• 添加用于测试 Hermes 连接的新管理命令

0.1.0 (2016-04-13)

• 首次发布到 PyPI。