vector_db_to_pivot_road2.core module#

Main module logic.

exception vector_db_to_pivot_road2.core.InvalidConfigurationException#

Bases : Exception

exception vector_db_to_pivot_road2.core.InvalidInputDatabaseException#

Bases : Exception

exception vector_db_to_pivot_road2.core.SubprocessRunException#

Bases : Exception

vector_db_to_pivot_road2.core.configure_r2gg(work_dir: Path, parameters: ProcessingParameters, input_db: PgDatabase, output_db: PgDatabase) → None#

Configure r2gg for pivot database creation

Raises InvalidConfigurationException if configuration is invalid

Paramètres:

  • work_dir (Path) – Input working directory. The folder must exist.

  • parameters (ProcessingParameters) – Processing parameters

  • input_db (PgDatabase) – Input database description

  • output_db (PgDatabase) – Output database description

vector_db_to_pivot_road2.core.log_r2gg_subprocess_output(pipe) → None#

Log r2gg process

Paramètres:

pipe – subprocess pipe

vector_db_to_pivot_road2.core.run(work_dir: Path, parameters: ProcessingParameters, input_db: PgDatabase, output_db: PgDatabase) → tuple[gpf_entrepot_toolbelt.orchestrator.status.Status, str]#

Main function running the logic.

Paramètres:

  • work_dir (Path) – Input working directory. The folder must exist.

  • parameters (ProcessingParameters) – Processing parameters

  • output_db (PgDatabase) – Input database description

  • input_db (PgDatabase) – Output database description

Type renvoyé:

Tuple[Status, str]

vector_db_to_pivot_road2.core.run_r2gg(work_dir: Path) → None#

Run r2gg-sql2pivot with previously created configuration file

Raises SubprocessRunException if an error occurs

Paramètres:

work_dir (Path) – Input working directory. The folder must exist.