ods_seller_asin_product.py 增加 buy_data 月销字段 对应hive表为 ods_asin_detail_product

Pyspark_job/sqoop_import/ods_seller_asin_product.py

@@ -40,8 +40,9 @@ if __name__ == '__main__':
             created_at,
             updated_at,
             null as month,
-            seller_id
-        from {import_table} 
+            seller_id,
+            buy_data
+        from {import_table}
         where 1=1
         and \$CONDITIONS
     """