基于事件的服务间通信库

event-isc的Python项目详细描述


服务间事件通信

这个库使用事件/观察者模式以解耦的方式处理服务间的通信。在

代码在发生某些事情时引发一个事件,该事件向已注册的侦听器激发通知。在

实施的通知包括:

  1. 芹菜任务
  2. HTTP请求

YAML文件配置

可以使用这样的yaml文件进行配置,作为初始化参数传递或在环境变量EVENTISC_CONFIG中传递

name_prefix:myapp.listeners:-kind:httpevent_name:myapp.user_createdurl:http://notification-service.mycompany.com/send-welcome/requests_kwargs:auth:["myuser","password"]request_format:jsondata:user_id:"{event_data['user'].id}"email:"{event_data['user'].email}"-kind:celeryevent_name_regex:myapp[.].*_createdqueue:foo_servicetask_name:foo_handle_createdtask_kwargs:event_name:{event_name}event_data:{event_data}

使用

^{pr2}$

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

推荐PyPI第三方库


热门话题
内部嵌套滚动视图的java Recyclerview?   返回空值的java MapPartitionFunction   java无法访问apache模块源代码中的系统定义的环境变量   java需要帮助确定用户输入的最大值和最小值   java检查文件是否存在,如果存在,则创建一个编号更高的新文件   针对许多不正确XML文档的XSD的XML验证在Java中不报告任何错误?   java有没有一种方法可以将json字符串甚至JSONObject发送给POSTMAN,而不在每个双引号前加斜杠?   java如何获得频域中两个音频信号的比率?   java 安卓 studio理解错误   java插入到部分填充的数组中   java使用流<String>创建流<CustomType>?   java开放式按键应用程序   java获取zxing生成的图像路径   使用shibboleth sso的java授权   java在运行时更改bean类名   javajooq如何从表中选择min'id'   java通过Eclipse web项目运行hadoop mapreduce字数   java同步方法与非同步方法同时执行   方法每次返回一个不同的加密字符数组   java获取ArrayList的每个元素中出现的特定字符的频率<String>