keepa毛重代表keepa重量

Pyspark_job/dwt/dwt_flow_keepa_asin.py

@@ -79,7 +79,7 @@ class DwtFlowKeepaAsin(object):
 
         # 读取keepa数据
         sql = f"""
-        select asin, package_length, package_width, package_height, weight from dim_keepa_asin_info where site_name = '{self.site_name}' and date_info = '{self.date_info}'
+        select asin, package_length, package_width, package_height, item_weight as weight from dim_keepa_asin_info where site_name = '{self.site_name}' and date_info = '{self.date_info}'
         """
         self.df_keepa_asin = self.spark.sql(sqlQuery=sql).repartition(40, 'asin').filter(
             (F.col("package_length") > 0) & (F.col("package_width") > 0) & (F.col("package_height") > 0) & (F.col("weight") > 0)