{ "info": { "author": "Daniel Debonzi", "author_email": "debonzi@gmail.com", "bugtrack_url": null, "classifiers": [ "Development Status :: 3 - Alpha", "Intended Audience :: Developers", "License :: OSI Approved :: GNU Library or Lesser General Public License (LGPL)", "Programming Language :: Python", "Programming Language :: Python :: 2.7", "Programming Language :: Python :: 3.5", "Programming Language :: Python :: 3.6", "Topic :: Software Development :: Libraries :: Python Modules" ], "description": "# GCES Subscriber Framework\n\n * `listeners/collector/__init__.py`\n\n ```python\nimport logging\nfrom gces import EventSubscriber\n\n\nTOPIC_NAME = 'super_service_1.events'\nSUBSCRIBER_NAME = 'collector'\n\ndef log_data(self, data):\n logger.info(data)\n\ndef subsetup_(config):\n es = EventSubscriber(TOPIC_NAME, SUBSCRIBER_NAME)\n es.register_fsub('LINK_ENABLE', log_data)\n es.register_fsub('LINK_DISABLE', log_data)\n\n config.register_subscriber(SUBSCRIBER_NAME, es)\n ```\n\n * `listeners/spammer/__init__.py`\n\n ```python\nimport logging\nfrom gces import EventSubscriber\n\n\nTOPIC_NAME = 'super_service_2.events'\nSUBSCRIBER_NAME = 'spammer'\n\ndef log_data(self, data):\n logger.info(data)\n\ndef subsetup_(config):\n es = EventSubscriber(TOPIC_NAME, SUBSCRIBER_NAME)\n es.register_fsub('SPAM_DETECTED', log_data)\n es.register_fsub('SPAM_REGISTERED', log_data)\n\n config.register_subscriber(SUBSCRIBER_NAME, es)\n ```\n\n * `subscriber.py`\n\n```python\nimport logging\n\nlogging.basicConfig()\nlogger = logging.getLogger()\nlogger.setLevel('INFO')\n\nimport signal, os\nimport importlib\n\nfrom gces_subsfm import Configurator\n\n\ndef create_app():\n config = Configurator()\n config.include('listeners.collector')\n config.include('listeners.spammer')\n\n return config\n\napp = application()\n\n```\n\n## Run Subscriber\n\n```bash\n$ gces-subsfm -A subscriber:app\n```", "description_content_type": "text/markdown", "docs_url": null, "download_url": "", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "", "keywords": "pubsub gces google", "license": "", "maintainer": "", "maintainer_email": "", "name": "gces-subsfm", "package_url": "https://pypi.org/project/gces-subsfm/", "platform": "", "project_url": "https://pypi.org/project/gces-subsfm/", "project_urls": null, "release_url": "https://pypi.org/project/gces-subsfm/0.0.1a0/", "requires_dist": null, "requires_python": "", "summary": "GCES Subscriber Framework", "version": "0.0.1a0" }, "last_serial": 4810786, "releases": { "0.0.1a0": [ { "comment_text": "", "digests": { "md5": "569d8d3263abc826a8b493bd90acffea", "sha256": "4c8954baaa297351c7dfd2d171e0fe08ac4b4c90a7b9542aaa700e1e392aace3" }, "downloads": -1, "filename": "gces_subsfm-0.0.1a0.tar.gz", "has_sig": false, "md5_digest": "569d8d3263abc826a8b493bd90acffea", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3158, "upload_time": "2019-02-12T13:22:39", "url": "https://files.pythonhosted.org/packages/f9/22/f2c315472a4a54551a52aa1ece15c8c8f251df827398c881913e81d6d7d0/gces_subsfm-0.0.1a0.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "569d8d3263abc826a8b493bd90acffea", "sha256": "4c8954baaa297351c7dfd2d171e0fe08ac4b4c90a7b9542aaa700e1e392aace3" }, "downloads": -1, "filename": "gces_subsfm-0.0.1a0.tar.gz", "has_sig": false, "md5_digest": "569d8d3263abc826a8b493bd90acffea", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3158, "upload_time": "2019-02-12T13:22:39", "url": "https://files.pythonhosted.org/packages/f9/22/f2c315472a4a54551a52aa1ece15c8c8f251df827398c881913e81d6d7d0/gces_subsfm-0.0.1a0.tar.gz" } ] }