RabbitMQ事件发送器

eventsender的Python项目详细描述


事件发送器

这是一个简单的事件发送器,它将json可序列化消息发布到amqp服务器交换。它也可以作为django应用程序安装。

安装和配置

以下设置应作为环境变量或通过django设置模块提供:

EVENT_QUEUE_URL=os.environ.get('EVENT_QUEUE_URL')EVENT_QUEUE_EXCHANGE=os.environ.get('EVENT_QUEUE_EXCHANGE')EVENT_QUEUE_ROUTING_KEY=os.environ.get('EVENT_QUEUE_ROUTING_KEY','')

EVENT_QUEUE_ROUTING_KEY是可选的,可以省略(默认情况下假定为空)。

使用量

示例:

fromeventsenderimportsend_eventsend_event({'type':'user.subscribed','username':'john_doe'})

EVENT_QUEUE_EXCHANGE=some_exchange EVENT_QUEUE_URL=amqp://guest:guest@localhost:5672/host python -c \
"import eventsender; eventsender.send_event({'type': 'event_type', 'somedata': {'key': 'value'}})"

运行测试

只需运行nosetests即可对当前设置运行测试。

关于

这个软件是由byte带来的,byte是一家位于荷兰阿姆斯特丹的网络托管提供商。我们专攻 快速安全的magento托管和可扩展的集群托管。

查看我们的Github page了解更多开源软件或our site 了解我们的产品和技术。看起来很有趣?伸出手来joining the team。 如果你在城里的话,顺便来喝杯好咖啡吧!

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
使用C在任何情况下检索Java安装目录#   javascript ClassNotFoundException在NativeScript中使用。扩展()   如何将Hadoop路径对象转换为Java文件对象   JavaJersey 2.22:我应该在哪里定义REST资源的位置?   java复制数组并使用printall()方法将1添加到其大小,以返回新数组中的所有int   在Java代码中使用JMeter JDBC连接   Java8流。findFirst()仅在排序后才有意义?   用于授权的Java swagger注释   java如何执行未使用execmavenplugin调用的“Premain”方法   java请求错误,状态:0弹出a4j:支持   Java JUnit、接口、类标题   java需要正则表达式来匹配字符串   java Springboot Wildfly 10部署错误jdk。找不到不支持的模块   java notifyDataSetChanged()不起作用   java搜索将对象之间的双向链接转换为JSON格式的正确方法   java在json中使用多个不同的嵌套对象来改进   java JPA:将LocalDateTime属性与生成器进行比较。currentTimestamp()   java在遗留应用程序中查找硬编码字符串