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 路径未标准化,可能会产生意外行为。

此条目是否有帮助?