diff --git a/routers/point.py b/routers/point.py index bea9ec4..beb7e10 100644 --- a/routers/point.py +++ b/routers/point.py @@ -21,11 +21,12 @@ def dest_partition(s: str) -> int: async def point(request: Request, items: DataModel): try: uid = items.public.get('x02') + app_id = items.public.get('b01') or items.public.get('#app_id') 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('#time') or item.get('b03') or item.get('b06') or item.get('#event_time') - print(f'uid:{uid} event_name:{event_name} event_time:{event_time}') + event_time = item.get('#time') or item.get('b03') or item.get('b06') or item.get('#event_time') + print(f'uid:{uid} event_name:{event_name} event_time:{event_time} app_id:{app_id}') public_data, _ = restore_field(items.public) rdb = request.app.state.redis