20200331

PSI_time.py

@@ -189,7 +189,10 @@ class PSIMonitor:
 
         # 分离数据.
         df_copy = self.mongo_df[[field, 'date_label', 'applied_type', 'applied_channel', 'applied_at']].copy()
+        if field == 'guomei_audit_info#creditScore':
+            df_copy[field] = df_copy[field].apply(lambda x: x if 0 < x < 1 else np.nan)
         df_copy = df_copy[df_copy[field].notna()]
+
         if df_copy.shape[0] == 0:
             print('仍在空跑.')
             return None
@@ -343,7 +346,11 @@ class PSIMonitor:
 
         # 清洗数据.
         def clean_data(data):
+            if pd.isnull(data):
+                return np.nan
             try:
+                if data <= 0 or data > 999999:
+                    return np.nan
                 return float(data)
             except:
                 return np.nan