规范数据转换函数名

sync_amz_data/tasks/sb.py

@@ -9,8 +9,8 @@ logger = logging.getLogger(__name__)
 class SBTask(BaseTask):
     AmzAdClientClass = SBClient
 
-    def change_campaign(self, data: dict):
+    def change_campaigns(self, data: dict):
         return data
 
-    def change_ad_group(self, data: dict):
+    def change_groups(self, data: dict):
         return data

sync_amz_data/tasks/sp.py

@@ -1,14 +1,9 @@
 from sync_amz_data.public import SPClient
+from ._base import BaseTask
 
 
-class SpTask:
-    def __init__(self):
-        pass
+class SpTask(BaseTask):
+    AmzAdClientClass = SPClient
 
-    def consume(self, data: dict):
-        pass
-
-    def work(self, task_info: dict):
-        sp_cli = SPClient(**task_info)
-        for data in sp_cli.iter_campaigns():
-            self.consume(data)
+    def change_campaigns(self, data: dict):
+        return data

sync_amz_data/tools.py

@@ -5,7 +5,7 @@ from datetime import date, datetime, timezone
 def timestamp2utc_dt(timestamp: int, _format: str = "%Y-%m-%d %H:%M:%S") -> [str, datetime]:
     if len(str(timestamp)) == 13:  # _ms
         timestamp = int(timestamp / 1000)
-    utc_dt = datetime.fromtimestamp(timestamp, tz=timezone.utc)
+    utc_dt = datetime.utcfromtimestamp(timestamp)
     if _format:
         return utc_dt.strftime(_format)
     return utc_dt