mirror of https://github.com/dapr/quickstarts.git
17 lines
373 B
Python
17 lines
373 B
Python
from cloudevents.sdk.event import v1
|
|
from dapr.ext.grpc import App
|
|
import logging
|
|
|
|
import json
|
|
|
|
app = App()
|
|
|
|
logging.basicConfig(level = logging.INFO)
|
|
|
|
@app.subscribe(pubsub_name='order_pub_sub', topic='orders')
|
|
def mytopic(event: v1.Event) -> None:
|
|
data = json.loads(event.Data())
|
|
logging.info('Subscriber received: ' + str(data))
|
|
return '', 200
|
|
|
|
app.run(6002) |