浏览代码

添加SbTargets数据接入

wengao 1 年之前
父节点
当前提交
2114c7ebc7
共有 1 个文件被更改,包括 2 次插入2 次删除
  1. 2 2
      sync_amz_data/DataTransform/Data_ETL.py

+ 2 - 2
sync_amz_data/DataTransform/Data_ETL.py

@@ -535,8 +535,8 @@ class SB_ETL(SBClient, Common_ETLMethod):
             lambda x: self.get_keyOvalue(x, 'type'))
             lambda x: self.get_keyOvalue(x, 'type'))
         df_targets['expressions_value'] = df_targets['expressions'].map(
         df_targets['expressions_value'] = df_targets['expressions'].map(
             lambda x: self.get_keyOvalue(x, 'value'))
             lambda x: self.get_keyOvalue(x, 'value'))
-        df_targets['resolvedExpressions_type'] = df_targets['resolvedExpressions'].map(lambda x:self.get_keyOvalue(x,'type'))
-        df_targets['resolvedExpressions_value'] = df_targets['resolvedExpressions'].map(lambda x:self.get_keyOvalue(x,'value'))
+        df_targets['resolvedExpressions_type'] = df_targets['resolvedExpressions'].map(lambda x:self.get_keyOvalue(x, 'type'))
+        df_targets['resolvedExpressions_value'] = df_targets['resolvedExpressions'].map(lambda x:self.get_keyOvalue(x, 'value'))
         return self.columnsName_modify(df_targets)
         return self.columnsName_modify(df_targets)
 
 
     def budget_ETL(self, campaign_ids: list):
     def budget_ETL(self, campaign_ids: list):