基础
指南
参考
系统测试
资源
提交
airflow.providers.common.io
airflow.providers.common.io.assets
airflow.providers.common.io.assets.file
create_asset(*, path[, extra])
create_asset
sanitize_uri(uri)
sanitize_uri
convert_asset_to_openlineage(asset, lineage_context)
convert_asset_to_openlineage
使用有效的 AIP-60 URI 和上下文辅助将资产转换为 OpenLineage。
Windows 路径未标准化,可能会产生意外行为。
此条目是否有帮助?
create_asset()
sanitize_uri()
convert_asset_to_openlineage()