Doris导出变体属性表

Pyspark_job/dim/dim_asin_detail.py

@@ -498,8 +498,9 @@ class DimAsinDetail(object):
                 )
                 print("导出父ASIN最新变体信息到doris：")
                 df_doris = df_asin_variat_agg.select(
-                    "parent_asin", F.lit(self.date_info).alias("date_info"), "asin_crawl_date", "variation_info", "attr_info")
-                table_columns="parent_asin, date_info, asin_crawl_date, variation_info, attr_info"
+                    "parent_asin", F.lit(self.date_info).alias("date_info"), "asin_crawl_date", "variation_info", "attr_info",
+                    F.date_format(F.current_timestamp(), "yyyy-MM-dd HH:mm:ss").alias("updated_at"))
+                table_columns = "parent_asin, date_info, asin_crawl_date, variation_info, attr_info, updated_at"
                 DorisHelper.spark_export_with_columns(df_save=df_doris, db_name=self.doris_db, table_name=self.parent_asin_latest_detail_table, table_columns=table_columns)
             else:
                 print("不用导出旧数据到doris中")