Google Cloud Platform Pub/Sub toolbox
- GCP project with a Pub/Sub up & running.
- GCP service account and the credential file
private_key.jsonassociated.
pip install .import json
from pubsub.op import publisher
data = {"field1" : "value1", "field2" : "value2"}
event = json.dumps(data)
publisher.publish("PROJECT_ID", "TOPIC_ID", "private_key.json", event)Start a background thread to receive messages from Pub/Sub and calls a callback with each message received.
from pubsub.op import consumer
consumer.consume("PROJECT_ID", "SUBSCRIBER_ID", "private_key.json")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent