|
@@ -1,3 +1,4 @@
|
|
|
+import logging
|
|
|
from sync_amz_data.public.amz_ad_client import SPClient, Account, SBClient, SDClient, BaseClient
|
|
|
import pandas as pd
|
|
|
import numpy as np
|
|
@@ -121,6 +122,12 @@ class Common_ETLMethod(BaseClient):
|
|
|
# df_report.to_excel("df.xlsx")
|
|
|
return df_report
|
|
|
|
|
|
+ def today_(self):
|
|
|
+ timeZone_ = self.timeZone()
|
|
|
+ today_ = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ logging.info(f"timezone:{timeZone_},today:{today_}")
|
|
|
+ print(timeZone_,today_)
|
|
|
+ return timeZone_,today_
|
|
|
|
|
|
class Acount_ETL(Account, Common_ETLMethod):
|
|
|
def portfolio_ETL(self):
|
|
@@ -172,8 +179,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return self.columnsName_modify(df_budget)
|
|
|
|
|
|
def reportV3_campaign_spCampaignsETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -209,8 +215,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_adGroup_spCampaignsETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -247,8 +252,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
|
|
|
#
|
|
|
def reportV3_campaignPlacement_spCampaignsETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -287,8 +291,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_targeting_spTargetingETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -328,8 +331,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_searchTerm_spSearchTermETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -369,8 +371,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_advertiser_spAdvertisedProductETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -407,8 +408,7 @@ class SP_ETL(SPClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_asin_spPurchasedProductETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -487,8 +487,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return self.columnsName_modify(df_budget)
|
|
|
|
|
|
def reportV3_campaign_sbCampaigns_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -527,8 +526,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
|
|
|
|
|
|
def reportV3_purchasedAsinRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -559,8 +557,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
|
|
|
def reportV2_campaignsRecord_ETL(self, conn, params={}):
|
|
|
print(params)
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
|
|
@@ -592,8 +589,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
|
|
|
def reportV2_campaignsVideo_ETL(self, conn, params={}):
|
|
|
print(params)
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'campaigns'
|
|
@@ -626,8 +622,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
|
|
|
def reportV2_placementRecord_ETL(self, conn, params={}):
|
|
|
print(params)
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'campaigns'
|
|
@@ -655,8 +650,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_placementVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'campaigns'
|
|
@@ -687,8 +681,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adGroupsRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'adGroups'
|
|
@@ -718,8 +711,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adGroupsVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'adGroups'
|
|
@@ -749,8 +741,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_targetsRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'targets'
|
|
@@ -780,8 +771,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_targetsVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'targets'
|
|
@@ -812,8 +802,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_keywordsRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'keywords'
|
|
@@ -843,8 +832,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_keywordsVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'keywords'
|
|
@@ -875,8 +863,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_searchtermsRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'keywords'
|
|
@@ -901,8 +888,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_searchtermsVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'keywords'
|
|
@@ -930,8 +916,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adsRecord_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'ads'
|
|
@@ -959,8 +944,7 @@ class SB_ETL(SBClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adsVideo_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'ads'
|
|
@@ -1029,8 +1013,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return self.columnsName_modify(df_budget)
|
|
|
|
|
|
def reportV3_campaign_sdCampaigns_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1066,8 +1049,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_campaignMT_sdCampaigns_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1103,8 +1085,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_adgroup_sdAdGroup_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1141,8 +1122,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_adgroupMT_sdAdGroup_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1179,8 +1159,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_targeting_sdTargeting_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1221,8 +1200,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_targetingMT_sdTargeting_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1264,8 +1242,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_advertiser_sdAdvertisedProduct_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1304,8 +1281,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[params['columns']]
|
|
|
|
|
|
def reportV3_asin_sdPurchasedProduct_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("endDate") == None:
|
|
|
params["endDate"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y-%m-%d")
|
|
|
if params.get("startDate") == None:
|
|
@@ -1353,8 +1329,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_campaignsRecord_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'campaigns'
|
|
@@ -1375,8 +1350,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_campaignsRecord_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'campaigns'
|
|
@@ -1414,8 +1388,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_adGroupsRecord_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'adGroups'
|
|
@@ -1434,8 +1407,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adGroupsRecord_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'adGroups'
|
|
@@ -1470,8 +1442,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_productAds_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'productAds'
|
|
@@ -1491,8 +1462,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_productAds_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|
|
|
params['record_type'] = 'productAds'
|
|
@@ -1528,8 +1498,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_targets_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1551,8 +1520,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_targets_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1587,8 +1555,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_asins_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1610,8 +1577,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_asins_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1650,8 +1616,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
] # 'matchedTarget'
|
|
|
|
|
|
def reportV2_campaign_matchedTarget_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1674,8 +1639,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_campaign_matchedTarget_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1712,8 +1676,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
] # , 'matchedTarget'
|
|
|
|
|
|
def reportV2_adGroups_matchedTarget_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1735,8 +1698,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_adGroups_matchedTarget_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1771,8 +1733,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
]
|
|
|
|
|
|
def reportV2_targets_matchedTarget_t2_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime(
|
|
@@ -1793,8 +1754,7 @@ class SD_ETL(SDClient, Common_ETLMethod):
|
|
|
return df_report[metric]
|
|
|
|
|
|
def reportV2_targets_matchedTarget_t3_ETL(self, conn, params={}):
|
|
|
- timeZone_ = self.timeZone()
|
|
|
- today = datetime.now(tz=pytz.timezone(timeZone_))
|
|
|
+ timeZone_,today = self.today_()
|
|
|
if params.get("date") == None:
|
|
|
params["date"] = (
|
|
|
datetime(today.year, today.month, today.day) - timedelta(days=1)).strftime("%Y%m%d")
|