airflow.providers.common.compat.lineage.entities

定义用于提供血缘信息的实体基类。

文件

文件实体。指代一个文件。

用户

用户实体。标识一个用户。

标签

标签或分类实体。

表的列。

表实体。

函数

default_if_none(arg)

当为 None 时获取默认值。

模块内容

class airflow.providers.common.compat.lineage.entities.File[source]

文件实体。指代一个文件。

template_fields: ClassVar = ('url',)[source]
url: str[source]
type_hint: str | None = None[source]
class airflow.providers.common.compat.lineage.entities.User[source]

用户实体。标识一个用户。

email: str[source]
first_name: str | None = None[source]
last_name: str | None = None[source]
template_fields: ClassVar = ('email', 'first_name', 'last_name')[source]
class airflow.providers.common.compat.lineage.entities.Tag[source]

标签或分类实体。

tag_name: str[source]
template_fields: ClassVar = ('tag_name',)[source]
class airflow.providers.common.compat.lineage.entities.Column[source]

表的列。

name: str[source]
description: str | None = None[source]
data_type: str[source]
tags: list[Tag] = [][source]
template_fields: ClassVar = ('name', 'description', 'data_type', 'tags')[source]
airflow.providers.common.compat.lineage.entities.default_if_none(arg)[source]

当为 None 时获取默认值。

class airflow.providers.common.compat.lineage.entities.Table[source]

表实体。

database: str[source]
cluster: str[source]
name: str[source]
tags: list[Tag] = [][source]
description: str | None = None[source]
columns: list[Column] = [][source]
owners: list[User] = [][source]
extra: dict[str, Any][source]
type_hint: str | None = None[source]
template_fields: ClassVar = ('database', 'cluster', 'name', 'tags', 'description', 'columns', 'owners', 'extra')[source]

此条目有帮助吗?