Google Cloud Event System.
Project description
GCES - Google Cloud Event System
Goals
This project aims make it easier to have a global Event Publisher/Event Subscriber system to be used accross services.
Architecture
Quick Event Notification Example
from gces import EventPublisher
ept = EventPublisher('gces')
ept.notify('SIGNUP_EVENT', {'user_id': 1234})
ept.notify('LOGIN_EVENT', {'user_id': 4321})
Quick Event Subscription Example
import time
from gces import (
EventSubscriber
)
def example_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:
while True:
time.sleep(200)
except KeyboardInterrupt:
print('Bye!!!!')
Google Cloud Credentials
- Create Credentials at Google
- export GOOGLE_APPLICATION_CREDENTIALS=$(pwd)/<credentials_file>.json
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-0.0.13a0.tar.gz
(5.6 kB
view details)
File details
Details for the file gces-0.0.13a0.tar.gz
.
File metadata
- Download URL: gces-0.0.13a0.tar.gz
- Upload date:
- Size: 5.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.2.0 pkginfo/1.5.0.1 requests/2.24.0 setuptools/50.3.0 requests-toolbelt/0.9.1 tqdm/4.49.0 CPython/3.6.7
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | b3422e6150b23cbc75eb23be9e19b94e672c9a9773def386dbb2d528793e6b80 |
|
MD5 | 82a2e854360158bfa05f0453bf1e54c4 |
|
BLAKE2b-256 | 5d5b7f034a311cbf92e5e1ec017f09d216381a4f9c80dd1ab7306c6c1747fbaa |