Browse Source

ETL_update

huangyifan 1 year ago
parent
commit
7e63858e95
1 changed files with 3 additions and 3 deletions
  1. 3 3
      sync_amz_data/DataTransform/Data_ETL.py

+ 3 - 3
sync_amz_data/DataTransform/Data_ETL.py

@@ -46,7 +46,7 @@ class Acount_ETL(Account,Common_ETLMethod):
     def portfolio_ETL(self):
         list_portfolio = self.get_portfolios()
         df_portfolio = pd.json_normalize(list_portfolio)
-        print(self.columnsName_modify(df_portfolio))
+        # print(self.columnsName_modify(df_portfolio))
         return self.columnsName_modify(df_portfolio)
 
 class SP_ETL(SPClient,Common_ETLMethod):
@@ -127,7 +127,7 @@ class SB_ETL(SBClient,Common_ETLMethod):
         list_budget = self.get_budget(campaignIds = campaign_ids)['success']
         df_budget = pd.json_normalize(list_budget)
         df_budget = self.TZ_Deal(df_budget,["usageUpdatedTimestamp"])
-        print(df_budget)
+        return self.columnsName_modify(df_budget)
 
 class SD_ETL(SDClient,Common_ETLMethod):
     def campaigns_ETL(self):
@@ -153,7 +153,7 @@ class SD_ETL(SDClient,Common_ETLMethod):
         list_targets = [row for _ in list(self.iter_targets(**param)) for row in _]
         df_targets = pd.json_normalize(list_targets)
         df_targets = self.expression_split(df_targets, "resolvedExpression")
-        print(df_targets)
+        return self.columnsName_modify(df_targets)
 
     def budget_ETL(self,campaignsIds:list):
         list_budget = self.get_budget(campaignIds=campaignsIds)['success']