diff --git a/routers/point.py b/routers/point.py index a628804..0f7020b 100644 --- a/routers/point.py +++ b/routers/point.py @@ -20,7 +20,12 @@ def dest_partition(s: str) -> int: @router.post("/") async def point(request: Request, items: DataModel): try: - print(items.json()) + uid = items.public.get('x02') + for item in items.data: + if 'track' == (item.get('#type') or item.get('b02')): + event_name = item.get('x04') or item.get('#event_name') + event_time = item.get('b06') or item.get('#event_time') + print(f'uid:{uid} event_name:{event_name} event_time:{event_time}') public_data, _ = restore_field(items.public) rdb = request.app.state.redis