mirror of https://github.com/dapr/quickstarts.git
27 lines
602 B
Python
27 lines
602 B
Python
from dapr.ext.fastapi import DaprApp
|
|
from fastapi import FastAPI
|
|
from pydantic import BaseModel
|
|
|
|
app = FastAPI()
|
|
dapr_app = DaprApp(app)
|
|
|
|
|
|
class CloudEvent(BaseModel):
|
|
datacontenttype: str
|
|
source: str
|
|
topic: str
|
|
pubsubname: str
|
|
data: dict
|
|
id: str
|
|
specversion: str
|
|
tracestate: str
|
|
type: str
|
|
traceid: str
|
|
|
|
|
|
# Dapr subscription routes orders topic to this route
|
|
@dapr_app.subscribe(pubsub='orderpubsub', topic='orders')
|
|
def orders_subscriber(event: CloudEvent):
|
|
print('Subscriber received : %s' % event.data['orderId'], flush=True)
|
|
return {'success': True}
|