Merge branch 'master' into yifan

sync_amz_data/public/amz_ad_client.py

@@ -390,7 +390,7 @@ class SBClient(BaseClient):
             body["maxResults"] = 100
         while True:
             info: dict = self.get_ads(**body)
-            print(info)
+            # print(info)
             yield from info["ads"]
             if not info.get("nextToken"):
                 break

sync_amz_data/tasks/datainsert/SB/mysql_datainsert_sbads.py

@@ -32,7 +32,7 @@ class SbAds:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/sbads/list/"
+        self.upcreate_url_path = "api/sbads/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SB/mysql_datainsert_sbcampaign.py

@@ -32,7 +32,7 @@ class SbCampaign:
         self.profile_id = profile_id
         self.portfolioId = portfolioId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/sbcampaigns/list/"
+        self.upcreate_url_path = "api/sbcampaigns/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SB/mysql_datainsert_sbgroup.py

@@ -32,7 +32,7 @@ class SbGroup:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/sbgroups/list/"
+        self.upcreate_url_path = "api/sbgroups/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SB/mysql_datainsert_sbkeyword_v3.py

@@ -32,7 +32,7 @@ class SpKeyword:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/sbkeywords/list/"
+        self.upcreate_url_path = "api/sbkeywords/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SP/mysql_datainsert_sp_budget_recommendation.py

@@ -27,13 +27,13 @@ def request(url_path: str, method: str = "GET", head: dict = None, params: dict
     return resp.json()
 
 
-class SpCampaign:
+class SpBudgetRecommendation:
     def __init__(self, profile_id, portfolioId: list = None):
         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=999"
-        self.upcreate_url_path = "api/spbudgetrecommendation/list/"
+        self.camid_url_path = "api/ad_manage/spcampaigns/?limit=9999"
+        self.upcreate_url_path = "api/spbudgetrecommendation/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']
@@ -122,7 +122,7 @@ class SpCampaign:
 
 
 if __name__ == '__main__':
-    a = SpCampaign(profile_id="3006125408623189")
+    a = SpBudgetRecommendation(profile_id="3006125408623189")
     out = a.updata_create()
     # out = a.dataconvert()
     print(out)

sync_amz_data/tasks/datainsert/SP/mysql_datainsert_spads.py

@@ -32,7 +32,7 @@ class SpAds:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/spads/list/"
+        self.upcreate_url_path = "api/spads/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SP/mysql_datainsert_spcampaign.py

@@ -32,7 +32,7 @@ class SpCampaign:
         self.profile_id = profile_id
         self.portfolioId = portfolioId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/spcampaigns/list/"
+        self.upcreate_url_path = "api/spcampaigns/updata/?updata=1"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SP/mysql_datainsert_spgroup.py

@@ -32,7 +32,7 @@ class SpGroup:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/spgroups/list/"
+        self.upcreate_url_path = "api/spgroups/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/SP/mysql_datainsert_spkeyword.py

@@ -32,7 +32,7 @@ class SpKeyword:
         self.profile_id = profile_id
         self.portfolioId = campaignId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/spkeywords/list/"
+        self.upcreate_url_path = "api/spkeywords/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/alldata_insert.py

@@ -0,0 +1,31 @@
+from mysql_datainsert_portfolios import Portfolios
+from SP.mysql_datainsert_spcampaign import SpCampaign
+from SP.mysql_datainsert_spgroup import SpGroup
+from SP.mysql_datainsert_spkeyword import SpKeyword
+from SP.mysql_datainsert_sp_budget_recommendation import SpBudgetRecommendation
+from SP.mysql_datainsert_spads import SpAds
+
+
+pf = Portfolios("3006125408623189")
+pfo = pf.updata_create()
+print("Portfolios", pfo)
+
+spc = SpCampaign("3006125408623189")
+spco = spc.updata_create()
+print("SpCampaign", spco)
+
+spg = SpGroup("3006125408623189")
+spgo = spg.updata_create()
+print("SpGroup", spgo)
+
+spk = SpKeyword("3006125408623189")
+spko = spk.updata_create()
+print("SpKeyword", spko)
+
+spa = SpAds("3006125408623189")
+spao = spa.updata_create()
+print("SpAds", spao)
+
+spbr = SpBudgetRecommendation("3006125408623189")
+spbro = spbr.updata_create()
+print("SpBudgetRecommendation", spbr)

sync_amz_data/tasks/datainsert/mysql_datainsert_portfolios.py

@@ -31,7 +31,7 @@ class Portfolios:
     def __init__(self, profile_id):
         self.profile_id = profile_id
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/portfolios/list/"
+        self.upcreate_url_path = "api/portfolios/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

sync_amz_data/tasks/datainsert/mysql_datainsert_sdcampaign.py

@@ -31,7 +31,7 @@ class SpCampaign:
         self.profile_id = profile_id
         self.portfolioId = portfolioId
         self.re_url_path = "api/ad_manage/profiles/"
-        self.upcreate_url_path = "api/sdcampaigns/list/"
+        self.upcreate_url_path = "api/sdcampaigns/updata/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']