Commit 75ae57fd by chenyuanjie

fix

parent a4290282
...@@ -37,7 +37,7 @@ class DimAsinProfitRateInfo(object): ...@@ -37,7 +37,7 @@ class DimAsinProfitRateInfo(object):
# 读取keepa数据 # 读取keepa数据
sql = f""" sql = f"""
select asin, package_length, package_width, package_height, weight select asin, package_length, package_width, package_height, item_weight as weight
from dim_keepa_asin_info where site_name = '{self.site_name}'; from dim_keepa_asin_info where site_name = '{self.site_name}';
""" """
self.df_keepa_asin = self.spark.sql(sqlQuery=sql).repartition(40, 'asin') self.df_keepa_asin = self.spark.sql(sqlQuery=sql).repartition(40, 'asin')
......
...@@ -179,7 +179,7 @@ class DorisHelper(object): ...@@ -179,7 +179,7 @@ class DorisHelper(object):
.option("user", connection_info['user']) \ .option("user", connection_info['user']) \
.option("password", connection_info['pwd']) \ .option("password", connection_info['pwd']) \
.option("doris.write.fields", f"{table_columns}") \ .option("doris.write.fields", f"{table_columns}") \
.optin("doris.sink.properties.type", "DELETE") \ .option("doris.sink.properties.type", "DELETE") \
.option("doris.sink.properties.sequence_col", f"{update_field}") \ .option("doris.sink.properties.sequence_col", f"{update_field}") \
.option("doris.sink.batch.interval.ms", "30000") \ .option("doris.sink.batch.interval.ms", "30000") \
.option("doris.sink.properties.format", "json") \ .option("doris.sink.properties.format", "json") \
......
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