GCES用户框架
gces-subsfm的Python项目详细描述
GCES订户框架
listeners/collector/__init__.py
importloggingfromgcesimportEventSubscriberTOPIC_NAME='super_service_1.events'SUBSCRIBER_NAME='collector'deflog_data(self,data):logger.info(data)defsubsetup_(config):es=EventSubscriber(TOPIC_NAME,SUBSCRIBER_NAME)es.register_fsub('LINK_ENABLE',log_data)es.register_fsub('LINK_DISABLE',log_data)config.register_subscriber(SUBSCRIBER_NAME,es)
listeners/spammer/__init__.py
importloggingfromgcesimportEventSubscriberTOPIC_NAME='super_service_2.events'SUBSCRIBER_NAME='spammer'deflog_data(self,data):logger.info(data)defsubsetup_(config):es=EventSubscriber(TOPIC_NAME,SUBSCRIBER_NAME)es.register_fsub('SPAM_DETECTED',log_data)es.register_fsub('SPAM_REGISTERED',log_data)config.register_subscriber(SUBSCRIBER_NAME,es)
subscriber.py
importlogginglogging.basicConfig()logger=logging.getLogger()logger.setLevel('INFO')importsignal,osimportimportlibfromgces_subsfmimportConfiguratordefcreate_app():config=Configurator()config.include('listeners.collector')config.include('listeners.spammer')returnconfigapp=application()
运行订户
$ gces-subsfm -A subscriber:app
欢迎加入QQ群-->： 979659372
