airflow.providers.amazon.aws.utils.openlineage

模块内容

函数

get_facets_from_redshift_table(redshift_hook, table, ...)

查询 Redshift 表的元数据。

get_identity_column_lineage_facet(field_names, ...)

获取列血缘 facet。
airflow.providers.amazon.aws.utils.openlineage.get_facets_from_redshift_table(redshift_hook, table, redshift_data_api_kwargs, schema='public')[源代码]

查询 Redshift 表的元数据。

将创建 SchemaDatasetFacet 和 DocumentationDatasetFacet（如果表有描述）。

airflow.providers.amazon.aws.utils.openlineage.get_identity_column_lineage_facet(field_names, input_datasets)[源代码]

获取列血缘 facet。

将创建简单的血缘，其中每个源列对应于每个输入数据集中单个目标列，并且没有进行转换。

此条目是否对您有帮助？