Browse Source

log web service elapsed

chenhaiyang 4 năm trước cách đây
mục cha
commit
0e30a89792
2 tập tin đã thay đổi với 5 bổ sung0 xóa
  1. 3 0
      app/controllers/targets.py
  2. 2 0
      app/services/service.py

+ 3 - 0
app/controllers/targets.py

@@ -1,6 +1,7 @@
 # -*- coding: utf-8 -*-
 
 from abc import abstractmethod
+import time
 from typing import Dict, Tuple, Optional
 
 import arrow
@@ -292,6 +293,7 @@ class Co2TargetController(TargetController):
 
 @logger.catch()
 async def readjust_all_target(project_id: str, space_id: str, wechat_time: str):
+    start = time.perf_counter()
     async with AsyncClient() as client:
         transfer = TransferService(client, project_id, space_id)
         platform = DataPlatformService(client, project_id, space_id)
@@ -313,6 +315,7 @@ async def readjust_all_target(project_id: str, space_id: str, wechat_time: str):
         previous_changes = await transfer.env_database_get()
         temperature_changes = previous_changes.get('temperature')
         logger.debug(f'temperature previous changes: {nl}{temperature_changes}')
+    logger.debug(f'request web service elapsed: {time.perf_counter() - start}')
 
     if feedback.get('switch off') and feedback.get('switch off') > 0:
         need_switch_off = True

+ 2 - 0
app/services/service.py

@@ -32,11 +32,13 @@ class Service:
     @api_exception
     async def _get(self, url: URL, params: Optional[Dict] = None) -> Dict:
         raw_response = await self._client.get(url, params=params)
+        logger.debug(f'{url} - elapsed: {raw_response.elapsed.total_seconds()}')
 
         return raw_response.json()
 
     @api_exception
     async def _post(self, url: URL, params: Optional[Dict] = None, payload: Optional[Dict] = None) -> Dict:
         raw_response = await self._client.post(url, params=params, json=payload)
+        logger.debug(f'{url} - elapsed: {raw_response.elapsed.total_seconds()}')
 
         return raw_response.json()