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')[source]¶

查询 Redshift 获取表元数据。

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

airflow.providers.amazon.aws.utils.openlineage.get_identity_column_lineage_facet(field_names, input_datasets)[source]¶

获取列血缘 Facet。

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