adding another prototype fonctionalite
Browse files- satellites/edisonSat/edison.py +7 -1
- utils/logger.py +27 -0
satellites/edisonSat/edison.py
CHANGED
@@ -3,6 +3,7 @@ from typing import Dict,Any,List
|
|
3 |
import logging
|
4 |
import requests
|
5 |
import os
|
|
|
6 |
import json
|
7 |
|
8 |
role = "innovation et technologie"
|
@@ -18,7 +19,8 @@ class Edison(VegapunkSatellite):
|
|
18 |
"math": "http://api.mathjs.org/v4/",
|
19 |
"wolfram": "http://api.wolframalpha.com/v1/result"
|
20 |
}
|
21 |
-
logging.basicConfig(filename='edison_log.txt', level=logging.INFO)
|
|
|
22 |
|
23 |
def process_task(self, task: Dict[str, Any]) -> Dict[str, Any]:
|
24 |
task_type = task.get("type")
|
@@ -110,6 +112,10 @@ class Edison(VegapunkSatellite):
|
|
110 |
def log_activity(self, activity: str):
|
111 |
logging.info(activity)
|
112 |
|
|
|
|
|
|
|
|
|
113 |
def communicate_with_stellar(self, message: Dict[str, Any]) -> Dict[str, Any]:
|
114 |
self.log_activity(f"Communication avec Stellar : {message}")
|
115 |
return {"status": "Message reçu par Stellar", "details": message}
|
|
|
3 |
import logging
|
4 |
import requests
|
5 |
import os
|
6 |
+
from utils import logger
|
7 |
import json
|
8 |
|
9 |
role = "innovation et technologie"
|
|
|
19 |
"math": "http://api.mathjs.org/v4/",
|
20 |
"wolfram": "http://api.wolframalpha.com/v1/result"
|
21 |
}
|
22 |
+
# logging.basicConfig(filename='edison_log.txt', level=logging.INFO)
|
23 |
+
self.logger = logger.get_logger("edison")
|
24 |
|
25 |
def process_task(self, task: Dict[str, Any]) -> Dict[str, Any]:
|
26 |
task_type = task.get("type")
|
|
|
112 |
def log_activity(self, activity: str):
|
113 |
logging.info(activity)
|
114 |
|
115 |
+
|
116 |
+
|
117 |
+
|
118 |
+
|
119 |
def communicate_with_stellar(self, message: Dict[str, Any]) -> Dict[str, Any]:
|
120 |
self.log_activity(f"Communication avec Stellar : {message}")
|
121 |
return {"status": "Message reçu par Stellar", "details": message}
|
utils/logger.py
CHANGED
@@ -0,0 +1,27 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
import logging
|
2 |
+
|
3 |
+
|
4 |
+
from logging.handlers import RotatingFileHandler
|
5 |
+
|
6 |
+
def get_logger(name:str) :
|
7 |
+
logger = logging.getLogger(name)
|
8 |
+
logger.setLevel(logging.DEBUG)
|
9 |
+
|
10 |
+
#Gestionnaire de rotation de fichier
|
11 |
+
file_handler =RotatingFileHandler(f'{name}.log',maxBytes=5*1024*1024,backupCount=5)
|
12 |
+
file_handler.setLevel(logging.DEBUG)
|
13 |
+
|
14 |
+
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
|
15 |
+
file_handler.setFormatter(formatter)
|
16 |
+
|
17 |
+
#Ajout du gestionnaire de fichier au logger
|
18 |
+
console_handler = logging.StreamHandler()
|
19 |
+
console_handler.setLevel(logging.INFO)
|
20 |
+
console_handler.setFormatter(formatter)
|
21 |
+
|
22 |
+
#Ajout du gestionnaire de console au logger
|
23 |
+
|
24 |
+
logger.addHandler(file_handler)
|
25 |
+
logger.addHandler(console_handler)
|
26 |
+
|
27 |
+
return logger
|