Explorar o código

Merge branch 'wengao' of ASJ_ADS/sync_amz_data into master

wengao hai 1 ano
pai
achega
11d6b47b00

+ 3 - 3
sync_amz_data/tasks/datainsert/SP/mysql_datainsert_sp_budget_recommendation.py

@@ -32,7 +32,7 @@ class SpBudgetRecommendation:
         self.profile_id = profile_id
         self.portfolioId = portfolioId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.camid_url_path = "api/ad_manage/spcampaigns/?limit=9999"
+        self.camid_url_path = "api/ad_manage/spcampaigns/?updata=1&limit=9999"
         self.upcreate_url_path = "api/spbudgetrecommendation/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
@@ -68,7 +68,7 @@ class SpBudgetRecommendation:
                 out.append(i['campaignId'])
         return out
 
-    def get_spcampaign_data(self):
+    def get_budgetrecommendation_data(self):
         tem = SPClient(**self.AWS_CREDENTIALS)
         camid_list = self.get_campaignid()
         list_tem = tem.iter_budgetrecommendation(camid_list)
@@ -76,7 +76,7 @@ class SpBudgetRecommendation:
         return df_spbudgetrecommendation
 
     def dataconvert(self):
-        df = self.get_spcampaign_data()
+        df = self.get_budgetrecommendation_data()
         df.drop(columns='index', inplace=True)
         df['sevenDaysMissedOpportunities.startDate'] = pd.to_datetime(
             df['sevenDaysMissedOpportunities.startDate'], format='%Y%m%d').dt.strftime(