digkey 记录token

lib/apidigikey.py

@@ -7,9 +7,11 @@ import requests
 from retry import retry
 from retry import retry
 import token_lib
 import token_lib
 from utils.robots import dd_send_msg
 from utils.robots import dd_send_msg
+from log_manage import get_logger
 
 
+apidigikey_log = get_logger('apidigikey_token_info')
 PLATFORM = "apidigikey"
 PLATFORM = "apidigikey"
-LEVEL = "HH"
+LEVEL = "TM"
 BACK_NUM = 0
 BACK_NUM = 0
 MODE = "redis"
 MODE = "redis"
 MAIN_NUM = THREAD_NUM = 1
 MAIN_NUM = THREAD_NUM = 1
@@ -46,6 +48,8 @@ class DGTokenCrawler(token_lib.BaseTokenCrawler):
     def collect_token(self):
     def collect_token(self):
         try:
         try:
             access_token, refresh_token = self.get_token_by_refresh_token()
             access_token, refresh_token = self.get_token_by_refresh_token()
+            apidigikey_log.info(access_token)
+            apidigikey_log.info(refresh_token)
             return access_token, refresh_token
             return access_token, refresh_token
         except Exception:
         except Exception:
             dd_send_msg('digikey token同步失败：' + traceback.format_exc())
             dd_send_msg('digikey token同步失败：' + traceback.format_exc())
@@ -83,5 +87,6 @@ class DGTokenCrawler(token_lib.BaseTokenCrawler):
 
 
     def process(self, is_main):
     def process(self, is_main):
         access_token, refresh_token = self.collect_token()
         access_token, refresh_token = self.collect_token()
+
         self._redis.set(self.token_key, access_token)
         self._redis.set(self.token_key, access_token)
         self._redis.set(self.refresh_token_key, refresh_token)
         self._redis.set(self.refresh_token_key, refresh_token)

token_server.py

@@ -23,6 +23,7 @@ LEVEL_MAP = {
     "B": 30,  # 仅供测试用
     "B": 30,  # 仅供测试用
     "X": 60,
     "X": 60,
     "C": 60 * 5,
     "C": 60 * 5,
+    "TM": 60 * 20,
     "HH": 60 * 30,
     "HH": 60 * 30,
     "H": 60 * 60,
     "H": 60 * 60,
     "4H": 60 * 60 * 4,
     "4H": 60 * 60 * 4,