airflow.providers.amazon.aws.assets.s3¶

函数¶

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

airflow.providers.amazon.aws.assets.s3.create_asset(*, bucket, key, extra=None)[source]¶

airflow.providers.amazon.aws.assets.s3.sanitize_uri(uri)[source]¶

airflow.providers.amazon.aws.assets.s3.convert_asset_to_openlineage(asset, lineage_context)[source]¶

借助 hook 将具有有效 AIP-60 uri 的 Asset 转换为 OpenLineage。