|
@@ -107,7 +107,6 @@ def h_data_check(project, table, now_date):
|
|
|
try:
|
|
try:
|
|
|
dt = datetime.datetime.strftime(now_date, '%Y%m%d%H')
|
|
dt = datetime.datetime.strftime(now_date, '%Y%m%d%H')
|
|
|
# 测试 张博
|
|
# 测试 张博
|
|
|
- dt = "2024022319all0last0"
|
|
|
|
|
check_res = check_table_partition_exits(date=dt, project=project, table=table)
|
|
check_res = check_table_partition_exits(date=dt, project=project, table=table)
|
|
|
if check_res:
|
|
if check_res:
|
|
|
sql = f'select * from {project}.{table} where dt = "{dt}"'
|
|
sql = f'select * from {project}.{table} where dt = "{dt}"'
|
|
@@ -153,7 +152,6 @@ def get_feature_data(project, table, now_date):
|
|
|
"""获取特征数据"""
|
|
"""获取特征数据"""
|
|
|
dt = datetime.datetime.strftime(now_date, '%Y%m%d%H')
|
|
dt = datetime.datetime.strftime(now_date, '%Y%m%d%H')
|
|
|
# 张博 测试
|
|
# 张博 测试
|
|
|
- dt = '2024022319all0last0'
|
|
|
|
|
records = get_data_from_odps(date=dt, project=project, table=table)
|
|
records = get_data_from_odps(date=dt, project=project, table=table)
|
|
|
feature_data = []
|
|
feature_data = []
|
|
|
for record in records:
|
|
for record in records:
|
zhangbo