no message

Pyspark_job/sqoop_import/ods_self_asin_detail.py

@@ -13,9 +13,9 @@ if __name__ == '__main__':
     assert site_name is not None, "site_name 不能为空！"
     assert date_type is not None, "date_type 不能为空！"
     assert date_info is not None, "date_info 不能为空！"
-
+    year = date_info.split("-")[0]
     db_type = 'postgresql_15'
-    import_table = f"{site_name}_self_asin_detail_{2025}"
+    import_table = f"{site_name}_self_asin_detail_{year}"
 
     hive_table = "ods_self_asin_detail"
     partition_dict = {
@@ -103,6 +103,7 @@ if __name__ == '__main__':
   REPLACE(REPLACE(REPLACE(variat_list, E'\n',' '), E'\r',' '), E'\t',' ') AS variat_list,
   REPLACE(REPLACE(REPLACE(bundle_asin_component_json, E'\n',' '), E'\r',' '), E'\t',' ') AS bundle_asin_component_json,
   REPLACE(REPLACE(REPLACE(cart_type, E'\n',' '), E'\r',' '), E'\t',' ') AS cart_type
+  REPLACE(REPLACE(REPLACE(site, E'\n',' '), E'\r',' '), E'\t',' ') AS site
 
 FROM {import_table}
 WHERE  date_info='{date_info}' AND \$CONDITIONS