ai_asin_detail_month_date_info新增导出字段launch_time_type

Pyspark_job/script/export_asin_detail_base.py

@@ -52,7 +52,8 @@ class ExportAsinDetailBase(object):
             first_category_rank,
             asin_price,
             asin_rating,
-            asin_total_comments
+            asin_total_comments,
+            asin_launch_time_type
         from dwt_flow_asin 
         where site_name = '{self.site_name}' 
           and date_type = '{self.date_type}' 
@@ -980,7 +981,8 @@ class ExportAsinDetailBase(object):
             F.col("asin_img_num").alias("img_num"), "variation_flag", "variation_num", F.col("asin_ao_val").alias("ao_val"),
             F.col("category_first_id").alias("category_id"), F.col("category_id").alias("category_current_id"), "parent_asin",
             F.col("first_category_rank").alias("bsr_rank"), F.col("asin_price").alias("price"), F.col("asin_rating").alias("rating"),
-            F.col("asin_total_comments").alias("total_comments"), "seller_id", "fb_country_name", "review_json_list"
+            F.col("asin_total_comments").alias("total_comments"), "seller_id", "fb_country_name", "review_json_list",
+            F.col("asin_launch_time_type").alias("launch_time_type")
         ).repartition(40, 'asin')
 
     def save_data(self):