|
@@ -48,6 +48,7 @@ def get_table_data(project, table, partition) -> list[dict]:
|
|
|
records = get_data_from_odps(date=partition, project=project, table=table)
|
|
records = get_data_from_odps(date=partition, project=project, table=table)
|
|
|
data = []
|
|
data = []
|
|
|
for record in records:
|
|
for record in records:
|
|
|
|
|
+ print(record)
|
|
|
tmp = {}
|
|
tmp = {}
|
|
|
for col_name in ["region", "videoid_array_sum", "videoid_array_avg"]:
|
|
for col_name in ["region", "videoid_array_sum", "videoid_array_avg"]:
|
|
|
tmp[col_name] = record[col_name]
|
|
tmp[col_name] = record[col_name]
|
zhangbo