asj_api接口添加X-Token头

sync_amz_data/public/asj_client.py

@@ -25,7 +25,7 @@ class AsjHttpClient:
         self.session.mount("http://", adapter)
 
     def _request(self, method, url, *, params=None, body=None):
-        headers = {"X-Token": ""}
+        headers = {"X-Token": "da4ab6bc5cbf1dfa"}
         resp = self.session.request(method, url, params=params, headers=headers, json=body)
         if resp.status_code >= 400:
             raise Exception(resp.text)

sync_amz_data/tasks/_base.py

@@ -1,7 +1,6 @@
 from functools import lru_cache
 import logging
 from typing import List
-from urllib.parse import urljoin
 
 from sync_amz_data.public import BaseClient, asj_api
 from sync_amz_data.settings import AWS_LWA_CLIENT, DATA_PATH
@@ -63,4 +62,4 @@ class BaseTask:
         pass
 
     def to_mysql(self, record: str, data: [dict, List[dict]]):
-        asj_api.create(urljoin(ASJ_URL_BASE, record), data)
+        asj_api.create(f"{ASJ_URL_BASE}{record}/", data)