airflow.providers.common.io.assets.file

函数

create_asset(*, path[, extra])

sanitize_uri(uri)

convert_asset_to_openlineage(asset, lineage_context)

借助上下文,将具有有效 AIP-60 URI 的资产转换为 OpenLineage 格式。

模块内容

airflow.providers.common.io.assets.file.create_asset(*, path, extra=None)[源码]
airflow.providers.common.io.assets.file.sanitize_uri(uri)[源码]
airflow.providers.common.io.assets.file.convert_asset_to_openlineage(asset, lineage_context)[源码]

借助上下文,将具有有效 AIP-60 URI 的资产转换为 OpenLineage 格式。

Windows 路径不是标准化的,可能导致意外行为。

本条目有帮助吗?