format code

applications/config/__init__.py

@@ -3,4 +3,4 @@ from .mysql_config import long_video_db_config
 
 # aliyun log sdk config
 
-from .aliyun_log_config import aliyun_log_config
+from .aliyun_log_config import aliyun_log_config

applications/config/aliyun_log_config.py

@@ -1,9 +1,8 @@
-
 # aliyun日志配置文件
 aliyun_log_config = {
     "endpoint": "cn-hangzhou.log.aliyuncs.com",
-    "logstore":"long_articles_job",
-    "project":"changwen-alg",
-    "access_key_id":"LTAIP6x1l3DXfSxm",
-    "access_key_secret":"KbTaM9ars4OX3PMS6Xm7rtxGr1FLon",
-}
+    "logstore": "long_articles_job",
+    "project": "changwen-alg",
+    "access_key_id": "LTAIP6x1l3DXfSxm",
+    "access_key_secret": "KbTaM9ars4OX3PMS6Xm7rtxGr1FLon",
+}

applications/service/__init__.py

@@ -1,5 +1,5 @@
 # 日志服务
 from .log_service import LogService
+
 # 实验
 from .get_cover import GetCoverService
-

applications/service/log_service.py

@@ -5,6 +5,7 @@ import json
 import datetime
 from aliyun.log import LogClient, PutLogsRequest, LogItem
 
+
 class LogService:
     def __init__(self, endpoint, access_key_id, access_key_secret, project, logstore):
         self.client = LogClient(endpoint, access_key_id, access_key_secret)
@@ -35,7 +36,7 @@ class LogService:
 
     def _put_log(self, contents: dict):
         timestamp = int(time.time())
-        contents['datetime'] = datetime.datetime.now().__str__()
+        contents["datetime"] = datetime.datetime.now().__str__()
         safe_items = [
             (str(k), json.dumps(v) if isinstance(v, (dict, list)) else str(v))
             for k, v in contents.items()
@@ -43,5 +44,7 @@ class LogService:
         log_item = LogItem(timestamp=timestamp, contents=safe_items)
         print(type(log_item))
         print(log_item)
-        req = PutLogsRequest(self.project, self.logstore, topic="", source="", logitems=[log_item])
+        req = PutLogsRequest(
+            self.project, self.logstore, topic="", source="", logitems=[log_item]
+        )
         self.client.put_logs(req)

applications/tasks/task_scheduler.py

@@ -1,6 +1,7 @@
 from applications.utils import task_schedule_response
 from applications.tasks.monitor_tasks import check_kimi_balance
 
+
 class TaskScheduler:
     def __init__(self, data, log_service):
         self.data = data