X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/predictops.git/blobdiff_plain/844b558b71ac568d904e8845ce203d31b68c776d..dc10b29095dc3e2d74b82b208fd4f4677e6a9c30:/main.py diff --git a/main.py b/main.py index 3d3739f..9ccb687 100644 --- a/main.py +++ b/main.py @@ -1,26 +1,22 @@ -from extomeAI.source import MeteoFrance +from lib.source import MeteoFrance -from celery import Celery -from configparser import ConfigParser -from logging.config import fileConfig from logging import getLogger +from logging.config import fileConfig from pathlib import Path from shutil import rmtree -from subprocess import Popen, PIPE fileConfig((Path.cwd() / 'config') / 'logging.cfg') logger = getLogger() -class ExtomeEngine: +class Engine: def __init__(self, clean = False): - logger.info("Extome-IA engine launched") + logger.info("Predictops engine launched") if clean: self.clean() - print("Ne pas oublier d'exporter la BDD dans pgModeler") - print("Ni de copier l'archive dans la data") - + print("To prevent from downloading again csv files, copy the archive in data rep") + def clean(self): # Cleaning the data directory logger.info("Cleaning and restoring data directory") @@ -29,30 +25,14 @@ class ExtomeEngine: rmtree(directory) p = Path(Path.cwd() / 'data') p.mkdir() - - # Cleaning the postgresql database - config = ConfigParser() - config.read((Path.cwd() / 'config') / 'main.cfg') - - host = config['postgresql']['host'] - user = config['postgresql']['user'] - port = config['postgresql']['port'] - dbname = config['postgresql']['dbname'] - - logger.info("PostgreSQL database deletion") - command = ['dropdb', '-h', host, '-U', user, '-p', port, dbname] - process = Popen(command, stdout=PIPE, stderr=PIPE) - process.communicate() - - logger.info("PostgreSQL database creation") - command = ['createdb', '-h', host, '-U', user, '-p', port, dbname] - process = Popen(command, stdout=PIPE, stderr=PIPE) - process.communicate() - + + def add_meteofrance(self): self.meteofrance = MeteoFrance() - - -engine = ExtomeEngine(clean = False) -engine.add_meteofrance() \ No newline at end of file + + +engine = Engine(clean = False) +engine.add_meteofrance() +engine.meteofrance.update() +print(len(engine.meteofrance.dated_features)) \ No newline at end of file