tijiao

lib/monitor_tools.py

@@ -181,7 +181,7 @@ class monitorTools:
         start_date = (datetime.now() - timedelta(days=7)).strftime("%Y-%m-%d %H:%M:%S")
 
         # SQL 查询
-        mysql_query = "SELECT COUNT(*) FROM dwd_f_nzj_baseinfo WHERE createtime >= %s AND createtime <= %s"
+        mysql_query = "SELECT COUNT(*) FROM jianyu_subjectdb.dwd_f_nzj_baseinfo WHERE createtime >= %s AND createtime <= %s"
         params = (start_date, end_date)
         conn=MysqlUtil.connect_to_mysql(host='192.168.3.149',port='4000',user='datagroup',password='Dgrpdb#2024@36',database='jianyu_subjectdb')
         count=MysqlUtil.execute_sql(conn,mysql_query,params)

tools/分数字段结果分析/DataExport_forTesting.py

@@ -206,15 +206,15 @@ excel_file = 'mongo_data_statistics_combined.xlsx'
 with pd.ExcelWriter(excel_file, engine='openpyxl') as writer:
     # 写入第一个sheet（断流监控_mongo库）
     df_mongo = pd.DataFrame([data_row_mongo], columns=columns)
-    df_mongo.to_excel(writer, sheet_name='断流监控_mongo库(每周)', index=False)
+    df_mongo.to_excel(writer, sheet_name='入库数据量监控-mongo(每周)', index=False)
 
     # 写入第二个sheet（断流监控—es）
     df_es = pd.DataFrame([data_row_es], columns=columns_es)
-    df_es.to_excel(writer, sheet_name='断流监控-es(每周)', index=False)
+    df_es.to_excel(writer, sheet_name='入库数据量监控-es(每周)', index=False)
 
     # 写入第三个sheet（数据时效监控）
     df_timeliness = pd.DataFrame([data_row_timeliness], columns=columns_timeliness)
-    df_timeliness.to_excel(writer, sheet_name='数据时效监控(每周平均值)', index=False)
+    df_timeliness.to_excel(writer, sheet_name='数据时效监控(7天平均值)', index=False)
 
 print(f"统计结果已写入Excel文件: {excel_file}")