周度预测调试

main_yuanyou_zhoudu.py

@@ -397,7 +397,7 @@ def predict_main():
              end_time=global_config['end_time'],
              )
 
-    # logger.info('模型训练完成')
+    logger.info('模型训练完成')
 
     logger.info('训练数据绘图ing')
     model_results3 = model_losss(sqlitedb, end_time=end_time)
@@ -415,14 +415,6 @@ def predict_main():
     logger.info('模型训练完成')
 
     push_market_value()
-    # # LSTM 单变量模型
-    # ex_Lstm(df,input_seq_len=input_size,output_seq_len=horizon,is_debug=is_debug,dataset=dataset)
-
-    # # lstm 多变量模型
-    # ex_Lstm_M(df,n_days=input_size,out_days=horizon,is_debug=is_debug,datasetpath=dataset)
-
-    # # GRU 模型
-    # # ex_GRU(df)
 
     # 发送邮件
     # m = SendMail(

models/nerulforcastmodels.py

@@ -948,6 +948,8 @@ def model_losss(sqlitedb, end_time):
             'accuracy', where_condition=f"created_dt <= '{end_time}'")
         if len(df_combined) < 100:
             len(df_combined) + ''
+        if df_combined['y'].isnull().sum() / len(df_combined) > 0.8:
+            len(df_combined) + ''
     except:
         df_combined = loadcsv(os.path.join(
             config.dataset, "cross_validation.csv"))