Noyau applicatif (core)

Internal logging utility for fabrictools.

fabrictools.core.logging.log(message: str, level: str = 'info') → None

Emit a timestamped line on the fabrictools logger.

Parameters:

• message (str) – Text to log.

• level (str) – One of info, warning, error, debug (case-insensitive).

Path resolution helpers for Microsoft Fabric resources.

Lakehouse helpers accept slash paths and SQL-style schema.table (first dot only) when the string has no path separators, e.g. dbo.PdC Extraction → dbo/PdC Extraction.

fabrictools.core.paths.build_lakehouse_read_path_candidates(relative_path: str) → List[str]

Build ordered candidate relative paths for Lakehouse reads.

Normalizes slashes, maps SQL-style schema.table (e.g. dbo.PdC Extraction) to schema/table when there is no slash, then may prepend Tables/dbo or Files when the path omits those prefixes (Fabric layout).

Parameters:

relative_path (str) – User-supplied path under the Lakehouse.

Returns:

Unique candidates in resolution order.

Return type:

list[str]

fabrictools.core.paths.build_lakehouse_write_path(relative_path: str) → str

Normalize a Lakehouse write path (Tables/dbo/... or Files/...).

Accepts SQL-style schema.table (e.g. dbo.PdC Extraction) when there is no slash; it is mapped to schema/table before applying Fabric layout rules.

Parameters:

relative_path (str) – Destination path fragment from the caller.

Returns:

Canonical relative path for writes.

Return type:

str

fabrictools.core.paths.get_lakehouse_abfs_path(lakehouse_name: str) → str

Resolve the full ABFS base path for a Lakehouse display name.

Parameters:

lakehouse_name (str) – Lakehouse name as shown in Fabric.

Returns:

abfsPath from lakehouse properties.

Return type:

str

Raises:

ValueError – If notebookutils is missing or resolution fails.

fabrictools.core.paths.get_warehouse_jdbc_url(warehouse_name: str) → str

Build a JDBC URL for a Fabric Warehouse (SQL endpoint + database).

Parameters:

warehouse_name (str) – Warehouse display name in Fabric.

Returns:

JDBC URL string for Spark jdbc format reads/writes.

Return type:

str

Raises:

ValueError – If notebookutils is missing or resolution fails.

SparkSession accessor for fabrictools.

fabrictools.core.spark.get_spark() → pyspark.sql.SparkSession

Return the active SparkSession, creating one if none exists.

Returns:

Current or newly built session.

Return type:

SparkSession

Core shared utilities for fabrictools.

Exports logging, Spark session access, and Fabric path / JDBC resolution helpers. See submodules fabrictools.core.logging, fabrictools.core.paths, fabrictools.core.spark.

fabrictools.core.build_lakehouse_read_path_candidates(relative_path: str) → List[str]

Build ordered candidate relative paths for Lakehouse reads.

Normalizes slashes, maps SQL-style schema.table (e.g. dbo.PdC Extraction) to schema/table when there is no slash, then may prepend Tables/dbo or Files when the path omits those prefixes (Fabric layout).

Parameters:

relative_path (str) – User-supplied path under the Lakehouse.

Returns:

Unique candidates in resolution order.

Return type:

list[str]

fabrictools.core.build_lakehouse_write_path(relative_path: str) → str

Normalize a Lakehouse write path (Tables/dbo/... or Files/...).

Accepts SQL-style schema.table (e.g. dbo.PdC Extraction) when there is no slash; it is mapped to schema/table before applying Fabric layout rules.

Parameters:

relative_path (str) – Destination path fragment from the caller.

Returns:

Canonical relative path for writes.

Return type:

str

fabrictools.core.get_lakehouse_abfs_path(lakehouse_name: str) → str

Resolve the full ABFS base path for a Lakehouse display name.

Parameters:

lakehouse_name (str) – Lakehouse name as shown in Fabric.

Returns:

abfsPath from lakehouse properties.

Return type:

str

Raises:

ValueError – If notebookutils is missing or resolution fails.

fabrictools.core.get_spark() → pyspark.sql.SparkSession

Return the active SparkSession, creating one if none exists.

Returns:

Current or newly built session.

Return type:

SparkSession

fabrictools.core.get_warehouse_jdbc_url(warehouse_name: str) → str

Build a JDBC URL for a Fabric Warehouse (SQL endpoint + database).

Parameters:

warehouse_name (str) – Warehouse display name in Fabric.

Returns:

JDBC URL string for Spark jdbc format reads/writes.

Return type:

str

Raises:

ValueError – If notebookutils is missing or resolution fails.

fabrictools.core.log(message: str, level: str = 'info') → None

Emit a timestamped line on the fabrictools logger.

Parameters:

• message (str) – Text to log.

• level (str) – One of info, warning, error, debug (case-insensitive).