|
|
@@ -32,6 +32,7 @@ logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(name)s - %(level
|
|
|
|
|
|
def get_partition_df(table, dt):
|
|
|
logger.info(f"开始下载: {table} -- {dt} 的数据")
|
|
|
+ df = pd.DataFrame()
|
|
|
try:
|
|
|
download_session = odps_client.get_download_session(table, dt)
|
|
|
logger.info(f"表: {table} 中的分区 {dt}, 共有 {download_session.count} 条数据")
|
