|
@@ -477,15 +477,11 @@ def get_feature_data(project, table, features, dt):
|
|
|
"""获取特征数据"""
|
|
"""获取特征数据"""
|
|
|
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 = []
|
|
|
- i = 0
|
|
|
|
|
for record in records:
|
|
for record in records:
|
|
|
- if i > 1000:
|
|
|
|
|
- break
|
|
|
|
|
item = {}
|
|
item = {}
|
|
|
for feature_name in features:
|
|
for feature_name in features:
|
|
|
item[feature_name] = record[feature_name]
|
|
item[feature_name] = record[feature_name]
|
|
|
feature_data.append(item)
|
|
feature_data.append(item)
|
|
|
- i += 1
|
|
|
|
|
feature_df = pd.DataFrame(feature_data)
|
|
feature_df = pd.DataFrame(feature_data)
|
|
|
return feature_df
|
|
return feature_df
|
|
|
|
|
|