GCES Subscriber Framework
Project description
GCES Subscriber Framework
listeners/collector/__init__.py
import logging
from gces import EventSubscriber
TOPIC_NAME = 'super_service_1.events'
SUBSCRIBER_NAME = 'collector'
def log_data(self, data):
logger.info(data)
def subsetup_(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
import logging
from gces import EventSubscriber
TOPIC_NAME = 'super_service_2.events'
SUBSCRIBER_NAME = 'spammer'
def log_data(self, data):
logger.info(data)
def subsetup_(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
import logging
logging.basicConfig()
logger = logging.getLogger()
logger.setLevel('INFO')
import signal, os
import importlib
from gces_subsfm import Configurator
def create_app():
config = Configurator()
config.include('listeners.collector')
config.include('listeners.spammer')
return config
app = application()
Run Subscriber
$ gces-subsfm -A subscriber:app
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
gces_subsfm-0.0.1a0.tar.gz
(3.2 kB
view hashes)