Updated docker python 3.12, requirements, code refactoring

Author: Federico Rossi

database-parser/python/Dockerfile

@@ -1,4 +1,4 @@
-FROM python:3.8
+FROM python:3.12
 
 COPY ./database-parser/requirements.txt /requirements.txt
 

database-parser/python/app/data/__init__.py

@@ -1,10 +1,10 @@
 import threading
 import logging
-from datetime import datetime
+import datetime
 from logging.config import dictConfig
 import json
 import requests
-from sqlalchemy import create_engine, Table, MetaData, text, select
+from sqlalchemy import create_engine, Table, MetaData, text
 from sqlalchemy.orm import Session
 from sqlalchemy.inspection import inspect
 from .util.utility import post_message, validate_model
@@ -41,7 +41,7 @@ def __init__(self, dialect, driver, user, password, host,
 
     def manage_data(self, results, primary_keys):
         row_numbers = 0
-        end_timestamp = datetime.utcnow().timestamp() * 1000
+        end_timestamp = datetime.datetime.now(datetime.UTC).timestamp() * 1000
 
         self.status_logger.info("Posting rows")
 
@@ -101,7 +101,7 @@ def extract_recent(self):
                     query = query.where(text(self.where))
 
                 results = session.execute(query)
-                primary_keys = [key.name for key in inspect(table).primary_key]
+                primary_keys = [key.name for key in inspect(table).primary_key()]
                 self.manage_data(results, primary_keys)
 
         except requests.RequestException:

database-parser/python/app/data/data_extraction.py

@@ -1,30 +1,32 @@
+from typing import Dict
+
 from pydantic import BaseModel
 
 
 class LogConfig(BaseModel):
     """Logging configuration to be set for the server"""
 
-    LOGGER_NAME: str = "mycoolapp"
+    LOGGER_NAME: str = "database-parser"
     LOG_FORMAT: str = "%(levelprefix)s | %(asctime)s | %(message)s"
     LOG_LEVEL: str = "DEBUG"
 
     # Logging config
-    version = 1
-    disable_existing_loggers = False
-    formatters = {
+    version: int = 1
+    disable_existing_loggers: bool = False
+    formatters: Dict = {
         "default": {
             "()": "uvicorn.logging.DefaultFormatter",
             "fmt": LOG_FORMAT,
             "datefmt": "%Y-%m-%d %H:%M:%S",
         },
     }
-    handlers = {
+    handlers: Dict = {
         "default": {
             "formatter": "default",
             "class": "logging.StreamHandler",
             "stream": "ext://sys.stderr",
         },
     }
-    loggers = {
+    loggers: Dict = {
         "database-parser": {"handlers": ["default"], "level": LOG_LEVEL},
     }