pubsub.py

from flask import Flask
from pubsub import pub
import provision

app = Flask(__name__)


@app.route('/')
def hello_world():
    print('Publish something via pubsub')
    anObj = dict(a=456, b='abc')
    pub.sendMessage('rootTopic', arg1=123, arg2=anObj)
    return 'Hello World!'


@app.before_first_request
def activate_job():
    pub.subscribe(provision.order_subscriber, 'rootTopic')


if __name__ == '__main__':
    app.run()


def order_subscriber(arg1, arg2=None):
    print('Function listener1 received:')
    print('  arg1 =', arg1)
    print('  arg2 =', arg2)