|
|
@@ -45,10 +45,14 @@ def check_data(project, table, partition) -> int:
|
|
|
|
|
|
def get_table_data(project, table, partition) -> list[dict]:
|
|
|
"""获取全部分区数据"""
|
|
|
+
|
|
|
records = get_data_from_odps(date=partition, project=project, table=table)
|
|
|
+ print(records)
|
|
|
+ print(len(records))
|
|
|
+ print(type(records))
|
|
|
+
|
|
|
data = []
|
|
|
for record in records:
|
|
|
- print(record)
|
|
|
tmp = {}
|
|
|
for col_name in ["region", "videoid_array_sum", "videoid_array_avg"]:
|
|
|
tmp[col_name] = record[col_name]
|
zhangbo