Voici la documentation : https://geoplateforme.pages.gpf-tech.ign.fr/documentation

Skip to content
Extraits de code Groupes Projets

feature: switch logs to user_

Tous les fils de conversation ont été résolus !
Fusionnées Julien Moura a demandé de fusionner feature/switch-logs-to-user-logs vers main
Tous les fils de conversation ont été résolus !
Affichage du commit ae691925
Suivant
Afficher la dernière version
1 fichier
+ 18
16
Comparer les modifications
  • Côte à côte
  • En ligne
+ 18
16
@@ -51,7 +51,7 @@ def check_data_structure(parameters: GpfOrchestratorParameters) -> bool:
):
return True
else:
logger.error("La structure de stored_data en sortie n'est pas compatible")
logger.user_error("La structure de stored_data en sortie n'est pas compatible")
return False
@@ -68,7 +68,7 @@ def compare_data_structure(
Returns:
bool: True si la structure est compatible, False sinon
"""
logger.info("Vérification de la strucutre de la Stored_data de sortie")
logger.user_info("Vérification de la strucutre de la Stored_data de sortie")
out_db = parameters.output_database
inspector = PgDatabaseInspector(out_db)
@@ -84,7 +84,7 @@ def compare_data_structure(
for i in range(table_mission_definition.GetFieldCount()):
field_name = table_mission_definition.GetFieldDefn(i).GetName()
if field_name.lower() not in db_mission_fields:
logger.error(
logger.user_error(
f"Le champ {field_name} du layer {table_mission_name} n'existe pas dans la stored_data de sortie."
)
return False
@@ -97,7 +97,7 @@ def compare_data_structure(
for i in range(table_cliches_definition.GetFieldCount()):
field_name = table_cliches_definition.GetFieldDefn(i).GetName()
if field_name.lower() not in db_cliches_fields:
logger.error(
logger.user_error(
f"Le champ {field_name} du layer {table_cliches_name} n'existe pas dans la stored_data de sortie."
)
return False
@@ -125,7 +125,7 @@ def create_data_to_publish(
layer = layer_datasource.GetLayerByName(layer_name)
layer_definition = layer.GetLayerDefn()
logger.info(f"Duplication du layer {vector_file}")
logger.user_info(f"Duplication du layer {vector_file}")
output_dir.mkdir(exist_ok=True, parents=True)
outfile = output_dir / f"{vector_file}.gpkg"
@@ -137,20 +137,20 @@ def create_data_to_publish(
geom_type=layer.GetLayerDefn().GetGeomType(),
)
logger.info(f"Création des champs du layer {vector_file}")
logger.user_info(f"Création des champs du layer {vector_file}")
for i in range(layer_definition.GetFieldCount()):
fieldDefn = layer_definition.GetFieldDefn(i)
if fieldDefn.GetNameRef() not in ["dataset_id", "dataset_identifier"]:
outLayer.CreateField(fieldDefn)
# On créé le nouveau champ
logger.info(
logger.user_info(
f"Ajout du champ dataset_identifier dans le layer {vector_file}"
)
ds_id_field = ogr.FieldDefn("dataset_identifier", ogr.OFTString)
ds_id_field.SetWidth(255)
outLayer.CreateField(ds_id_field, True)
logger.info(
logger.user_info(
f"Ajout des {layer.GetFeatureCount()} features au layer {vector_file}"
)
layer.ResetReading()
@@ -177,7 +177,7 @@ def create_data_to_publish(
return Status.SUCCESS
except Exception as e:
logger.error(f"TECHNICAL_ERROR - create_data_structure : {e}")
logger.user_error(f"TECHNICAL_ERROR - create_data_structure : {e}")
return Status.TECHNICAL_ERROR
@@ -240,7 +240,7 @@ def create_data_structure(
Status: Status de l'execution
"""
try:
logger.info("Création de la structure de la Stored_data de sortie")
logger.user_info("Création de la structure de la Stored_data de sortie")
logger.debug("Création de la table dataset")
layerCreationOptions = ["FID=temp_fid", "GEOMETRY_NAME=geom"]
@@ -285,7 +285,7 @@ def create_data_structure(
return Status.SUCCESS
except Exception as e:
logger.error(f"TECHNICAL_ERROR - create_data_structure : {e}")
logger.user_error(f"TECHNICAL_ERROR - create_data_structure : {e}")
return Status.TECHNICAL_ERROR
@@ -302,7 +302,7 @@ def delete_data_from_dataset_identifier(
Status: Status de l'execution
"""
try:
logger.info("Suppression des données de la Stored_data de sortie")
logger.user_info("Suppression des données de la Stored_data de sortie")
db = DatabaseUtils(database)
sql = f"""
@@ -313,7 +313,9 @@ def delete_data_from_dataset_identifier(
return Status.SUCCESS
except Exception as e:
logger.error(f"TECHNICAL_ERROR - delete_data_from_dataset_identifier : {e}")
logger.user_error(
f"TECHNICAL_ERROR - delete_data_from_dataset_identifier : {e}"
)
return Status.TECHNICAL_ERROR
@@ -332,7 +334,7 @@ def copie_data_from_vector_files(
Status: Status de l'execution
"""
try:
logger.info("Copie des données dans la Stored_data de sortie")
logger.user_info("Copie des données dans la Stored_data de sortie")
logger.debug("Copie des données de la table dataset")
datasource_to_pg(
@@ -355,7 +357,7 @@ def copie_data_from_vector_files(
return Status.SUCCESS
except Exception as e:
logger.error(f"TECHNICAL_ERROR - copie_data_from_vector_files : {e}")
logger.user_error(f"TECHNICAL_ERROR - copie_data_from_vector_files : {e}")
return Status.TECHNICAL_ERROR
@@ -509,7 +511,7 @@ def run(
return result
except Exception as e:
logger.error(f"TECHNICAL_ERROR: {e}")
logger.user_error(f"TECHNICAL_ERROR: {e}")
return Status.TECHNICAL_ERROR
Chargement en cours