修改关键词迭代器、修改导入操作-iter keywords

sync_amz_data/DataTransform/Data_ETL.py

@@ -1,4 +1,4 @@
-from sync_amz_data.public.amz_ad_client_02 import SPClient,Account,SBClient,SDClient
+from sync_amz_data.public.amz_ad_client import SPClient,Account,SBClient,SDClient
 import pandas as pd
 import numpy as np
 from dateutil.parser import parse
@@ -112,6 +112,7 @@ class SB_ETL(SBClient,Common_ETLMethod):
         df_keywords_SP = pd.json_normalize(list_keywords_SB)
         return self.columnsName_modify(df_keywords_SP)
 
+
     def targets_ETL(self):
         list_targets = list(self.iter_targets())
         df_targets = pd.json_normalize(list_targets)
@@ -135,4 +136,4 @@ if __name__ == '__main__':
     }
     ac_etl = SB_ETL(**AWS_CREDENTIALS)
     # print(ac_etl.budget_ETL(campaign_ids=["126327624499318"]))
-    print(ac_etl.get_budget(["144123082741012379"]))
+    print(ac_etl.keyword_ETL())

sync_amz_data/public/__init__.py

@@ -1,3 +1,3 @@
-from .amz_ad_client_02 import SPClient, SBClient, SDClient, BaseClient, AccountClient
+from .amz_ad_client import SPClient, SBClient, SDClient, BaseClient, AccountClient
 
 from .asj_client import asj_api

sync_amz_data/public/amz_ad_client.py

@@ -296,7 +296,7 @@ class SBClient(BaseClient):
 
     def get_keywords(self,**param):
         url_path = "/sb/keywords"
-        return self._request(url_path, method="GET")
+        return self._request(url_path, method="GET",params=param)
 
     def iter_keywords(self,**param):
         if "startIndex" not in param:
@@ -431,41 +431,42 @@ if __name__ == '__main__':
     # matchType=["broad","exact"]))
     sb = SBClient(**AWS_CREDENTIALS)
     # print(list(sb.iter_targets()))
-    print(sb.get_keyword_bidrecommendation(**{'campaignId': 27333596383941, 'keywords': [
-        {"matchType": 'broad', "keywordText": "4k security camera system"}]}))
-    print(sb.get_budget([27333596383941]))
+    # print(sb.get_keyword_bidrecommendation(**{'campaignId': 27333596383941, 'keywords': [
+    #     {"matchType": 'broad', "keywordText": "4k security camera system"}]}))
+    a = list(sb.iter_keywords())
+    print(a,len(a))
     # sd = SDClient(**AWS_CREDENTIALS)
     # print(sd.get_campaigns(startIndex=10, count=10))
 
-    sb = SBClient(**AWS_CREDENTIALS)
-    metrics = [
-        'applicableBudgetRuleId',
-        'applicableBudgetRuleName',
-        'attributedConversions14d',
-        'attributedConversions14dSameSKU',
-        'attributedDetailPageViewsClicks14d',
-        'attributedOrderRateNewToBrand14d',
-        'attributedOrdersNewToBrand14d',
-        'attributedOrdersNewToBrandPercentage14d',
-        'attributedSales14d',
-        'attributedSales14dSameSKU',
-        'attributedSalesNewToBrand14d',
-        'attributedSalesNewToBrandPercentage14d',
-        'attributedUnitsOrderedNewToBrand14d',
-        'attributedUnitsOrderedNewToBrandPercentage14d',
-        'campaignBudget',
-        'campaignBudgetType',
-        'campaignId',
-        'campaignName',
-        'campaignRuleBasedBudget',
-        'campaignStatus',
-        'clicks',
-        'cost',
-        'dpv14d',
-        'impressions',
-        'unitsSold14d',
-        'attributedBrandedSearches14d',
-        'topOfSearchImpressionShare']
+    # sb = SBClient(**AWS_CREDENTIALS)
+    # metrics = [
+    #     'applicableBudgetRuleId',
+    #     'applicableBudgetRuleName',
+    #     'attributedConversions14d',
+    #     'attributedConversions14dSameSKU',
+    #     'attributedDetailPageViewsClicks14d',
+    #     'attributedOrderRateNewToBrand14d',
+    #     'attributedOrdersNewToBrand14d',
+    #     'attributedOrdersNewToBrandPercentage14d',
+    #     'attributedSales14d',
+    #     'attributedSales14dSameSKU',
+    #     'attributedSalesNewToBrand14d',
+    #     'attributedSalesNewToBrandPercentage14d',
+    #     'attributedUnitsOrderedNewToBrand14d',
+    #     'attributedUnitsOrderedNewToBrandPercentage14d',
+    #     'campaignBudget',
+    #     'campaignBudgetType',
+    #     'campaignId',
+    #     'campaignName',
+    #     'campaignRuleBasedBudget',
+    #     'campaignStatus',
+    #     'clicks',
+    #     'cost',
+    #     'dpv14d',
+    #     'impressions',
+    #     'unitsSold14d',
+    #     'attributedBrandedSearches14d',
+    #     'topOfSearchImpressionShare']
     # sb.get_report(
     #     record_type="campaigns",
     #     report_date="20231008",