airflow.providers.google.assets.gcs¶

函数¶

`create_asset`(*, bucket, key[, extra])
`sanitize_uri`(uri)
`convert_asset_to_openlineage`(asset, lineage_context)	在hook的协助下，将具有有效AIP-60 uri的Asset转换为OpenLineage格式。

airflow.providers.google.assets.gcs.create_asset(*, bucket, key, extra=None)[source]¶

airflow.providers.google.assets.gcs.sanitize_uri(uri)[source]¶

airflow.providers.google.assets.gcs.convert_asset_to_openlineage(asset, lineage_context)[source]¶

在hook的协助下，将具有有效AIP-60 uri的Asset转换为OpenLineage格式。