全部打印

This commit is contained in:
wuaho 2021-08-18 16:50:43 +08:00
parent d6ae04b6f4
commit 06570b404a

View File

@ -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