谷歌云事件系统。

gces的Python项目详细描述


Build StatusPyPIPyPICoverage Status

GCES-谷歌云事件系统

目标

这个项目的目标是使使用accross服务的全局事件发布者/事件订阅者系统更加容易。

架构

Architecture

快速事件通知示例

fromgcesimportEventPublisherept=EventPublisher('gces')ept.notify('SIGNUP_EVENT',{'user_id':1234})ept.notify('LOGIN_EVENT',{'user_id':4321})

快速事件订阅示例

importtimefromgcesimport(EventSubscriber)defexample_run_subscriber_function(data):print("Data Received: {}".format(data))TOPIC_NAME='gces'SUBSCRIBER_NAME='gces_example'es=EventSubscriber(TOPIC_NAME,SUBSCRIBER_NAME)es.register_fsub('EXAMPLE_RUN_FUNCTION_PROCCESS'example_run_subscriber_function)es.start()if__name__=='__main__':try:whileTrue:time.sleep(200)exceptKeyboardInterrupt:print('Bye!!!!')

谷歌云凭据

  • Google处创建凭据
  • 导出google_application_credentials=$(pwd)/<;credentials_file>;.json

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

推荐PyPI第三方库


热门话题
ws-consumer服务地址中的java动态属性   java如何比较整数列表,然后按升序排序?   javascript我正在使用java脚本调用一个函数,但它没有调用代码下面的方法,也没有调用secretitnames()函数   在文本窗格中多次使用Java insertIcon图标   JavaMSAL安卓。AuthenticationActivity完成,但用于身份验证请求的线程池线程仍处于等待状态   if语句中的java多范围比较   java toString()表示输出   java如何在jcstrest测试中生成指令重新排序   java我怎样才能运行它?   web应用程序中使用Hibernate和Spring的java问题   如何将字符串数据写入Java文本文件   如何在java命令提示符下运行已签名的jar文件?   java从我的菜单调用RCP应用程序   java如何等待Canvas/GraphicsContext完成任务,然后再继续执行代码块?