Browse Source

datainsert系列代码;代码优化

wengao 1 năm trước cách đây
mục cha
commit
e24fc12764

+ 1 - 1
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

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

@@ -27,12 +27,12 @@ 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.camid_url_path = "api/ad_manage/spcampaigns/?limit=9999"
         self.upcreate_url_path = "api/spbudgetrecommendation/list/"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
@@ -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)

+ 1 - 1
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/list/?updata=1"
         self.heads = {'X-Token': "da4ab6bc5cbf1dfa"}
         self.refresh_token = self.get_refresh_token()
         self.lwa_client_id = AWS_LWA_CLIENT['lwa_client_id']

+ 31 - 0
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)