Skip to content

A
Amazon-Selection-Data
Commit f0a3b8c7 by chenyuanjie
Options

fix

parent 2a408ea3
Showing with 1 additions and 0 deletions
Pyspark_job/my_kafka/kafka_flow_asin_detail_to_doris.py
...@@ -807,6 +807,7 @@ class KafkaFlowAsinDetail(Templates): ...@@ -807,6 +807,7 @@ class KafkaFlowAsinDetail(Templates):
"account_name", # UDF + df_asin_seller 补充，卖家名称 "account_name", # UDF + df_asin_seller 补充，卖家名称
"buy_box_seller_type", # UDF，配送类型（1.自营/2.FBA/3.FBM/4.其他/0.未知） "buy_box_seller_type", # UDF，配送类型（1.自营/2.FBA/3.FBM/4.其他/0.未知）
"site_name", # df_seller_country，卖家所在地 "site_name", # df_seller_country，卖家所在地
"asin_type", # 派生：handle_asin_detail_all_type 算好(0默认/1内部/2书籍影视/3隐藏)
F.col("follow_sellers").alias("follow_sellers_count"), # Kafka，关注该 ASIN 的卖家数 F.col("follow_sellers").alias("follow_sellers_count"), # Kafka，关注该 ASIN 的卖家数
# ── LOB（Make-It-A-Bundle）──────────────────────────────────── # ── LOB（Make-It-A-Bundle）────────────────────────────────────
"asin_lob_info", # 派生：捆绑销售关联 ASIN 列表 "asin_lob_info", # 派生：捆绑销售关联 ASIN 列表
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment