|
@@ -27,7 +27,7 @@ class SP_ELT(SPClient):
|
|
|
|
|
|
def TZ_Deal(self,df, time_columns):
|
|
|
for time_column in time_columns:
|
|
|
- df[time_column] = df[time_column].map(lambda x: parse(x))
|
|
|
+ df[time_column] = df[time_column].map(lambda x: parse(x).strftime("%Y-%m-%d %H:%M:%S"))
|
|
|
df[time_columns] = df[time_columns].astype("datetime64")
|
|
|
return df
|
|
|
|
|
@@ -71,10 +71,10 @@ class SP_ELT(SPClient):
|
|
|
df_targets = self.TZ_Deal(df_targets, ["extendedData.creationDateTime", "extendedData.lastUpdateDateTime"])
|
|
|
return self.columnsName_modify(df_targets)
|
|
|
|
|
|
- def budget_ETL(self):
|
|
|
- list_budget = self.get_budget(campaign_ids = ["254478421786009"])
|
|
|
+ def budget_ETL(self,campaign_ids:list):
|
|
|
+ list_budget = self.get_budget(campaign_ids = campaign_ids)['success']
|
|
|
df_budget = pd.json_normalize(list_budget)
|
|
|
- # df_budget = self.TZ_Deal(df_budget,)
|
|
|
+ df_budget = self.TZ_Deal(df_budget,["usageUpdatedTimestamp"])
|
|
|
print(df_budget)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
@@ -85,4 +85,4 @@ if __name__ == '__main__':
|
|
|
'profile_id': "3006125408623189"
|
|
|
}
|
|
|
ac_etl = SP_ELT(**AWS_CREDENTIALS)
|
|
|
- print(ac_etl.keywords_ETL())
|
|
|
+ print(ac_etl.budget_ETL(campaign_ids=["126327624499318"]))
|