airflow.providers.google.assets.bigquery¶

函数¶

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

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

airflow.providers.google.assets.bigquery.create_asset(*, project_id, dataset_id, table_id, extra=None)[source]¶

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

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