This flask extension is used to: - run the actor service - subscribe to PubSub events
pip install flask-dapr
from flask import Flask, request
from flask_dapr import DaprApp
app = Flask('myapp')
dapr_app = DaprApp(app)
@dapr_app.subscribe(pubsub='pubsub', topic='some_topic', route='/some_endpoint')
def my_event_handler():
# request.data contains pubsub event
pass