调整数据处理底层

data_process.py

@@ -40,7 +40,7 @@ def preprocess_data_simple(df_input, is_train=False, hourly_time=None):
     df_input = df_input.reset_index(drop=True)
 
     # 价格变化最小量阈值
-    price_change_amount_threshold = 5
+    price_change_amount_threshold = 1
     df_input['_raw_price_diff'] = df_input.groupby(['gid', 'baggage_weight'], group_keys=False)['price_total'].diff()
 
     # 计算价格变化量

descending_cabin_task.py

@@ -134,7 +134,7 @@ def sync_policy(payload):
 
 def time_handle():
     now_time = datetime.now()
-    next_time = now_time + timedelta(hours=1)
+    next_time = now_time + timedelta(hours=2)
     next_ts = int(next_time.timestamp())
 
     expire_at = next_time + timedelta(minutes=1)