Commit 03e6435a authored by Dr.李's avatar Dr.李

update model fetch

parent 6c383e0e
...@@ -754,6 +754,7 @@ class SqlEngine(object): ...@@ -754,6 +754,7 @@ class SqlEngine(object):
model_version=None, model_version=None,
is_primary=True, is_primary=True,
model_id=None) -> pd.DataFrame: model_id=None) -> pd.DataFrame:
from alphamind.model.composer import DataMeta
conditions = [] conditions = []
...@@ -775,8 +776,10 @@ class SqlEngine(object): ...@@ -775,8 +776,10 @@ class SqlEngine(object):
model_df = pd.read_sql(query, self.engine) model_df = pd.read_sql(query, self.engine)
for i, model_desc in enumerate(model_df.model_desc): for i, data in enumerate(zip(model_df.model_desc, model_df.data_meta)):
model_desc, data_desc = data
model_df.loc[i, 'model'] = load_model(model_desc) model_df.loc[i, 'model'] = load_model(model_desc)
model_df.loc[i, 'data_meta'] = DataMeta.load(data_desc)
del model_df['model_desc'] del model_df['model_desc']
return model_df return model_df
...@@ -924,10 +927,10 @@ class SqlEngine(object): ...@@ -924,10 +927,10 @@ class SqlEngine(object):
if __name__ == '__main__': if __name__ == '__main__':
universe = Universe('ss', ['hs300'])
engine = SqlEngine() engine = SqlEngine()
ref_date = '2017-12-28' ref_date = '2018-02-08'
codes = universe.query(engine, dates=[ref_date]) df = engine.fetch_model(ref_date,
df = engine.fetch_trade_status(ref_date, codes.code.tolist()) model_type='LassoRegression',
model_version=2)
print(df) print(df)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment