no message

Pyspark_job/sqoop_export/dwt_bs_top100.py

@@ -25,6 +25,14 @@ if __name__ == '__main__':
     test_flag = CommonUtil.get_sys_arg(len(sys.argv) - 1, None)
     print(f"执行参数为{sys.argv}")
 
+    # ============================================================
+    # 数据有效范围守卫：品类调研仅 us + month + 从 2025-07 起(到最新月)。
+    # ============================================================
+    if not (site_name == 'us' and date_type == 'month'
+            and tuple(map(int, str(date_info).split('-'))) >= (2025, 7)):
+        print(f"[SKIP] 参数不在有效范围(仅 us/month/date_info>=2025-07)：site={site_name} type={date_type} date={date_info}，跳过导出")
+        sys.exit(0)
+
     # 品类调研只有月粒度
     assert date_type == DateTypes.month.name, f"仅支持 month, 传入 date_type={date_type}"
 

Pyspark_job/sqoop_export/dwt_bs_top100_change_rate.py

@@ -25,6 +25,14 @@ if __name__ == '__main__':
     test_flag = CommonUtil.get_sys_arg(len(sys.argv) - 1, None)
     print(f"执行参数为{sys.argv}")
 
+    # ============================================================
+    # 数据有效范围守卫：品类调研仅 us + month + 从 2025-07 起(到最新月)。
+    # ============================================================
+    if not (site_name == 'us' and date_type == 'month'
+            and tuple(map(int, str(date_info).split('-'))) >= (2025, 7)):
+        print(f"[SKIP] 参数不在有效范围(仅 us/month/date_info>=2025-07)：site={site_name} type={date_type} date={date_info}，跳过导出")
+        sys.exit(0)
+
     # 品类调研只有月粒度
     assert date_type == DateTypes.month.name, f"仅支持 month, 传入 date_type={date_type}"