airflow.providers.teradata.operators.teradata_compute_cluster

类

TeradataComputeClusterProvisionOperator

使用指定的计算组名称和计算配置文件名称创建新的计算集群。

TeradataComputeClusterDecommissionOperator

删除使用指定的计算组名称和计算配置文件名称创建的计算集群。

TeradataComputeClusterResumeOperator

用于恢复指定 Teradata Vantage Cloud Lake 计算集群的 Teradata 计算集群操作符。

TeradataComputeClusterSuspendOperator

用于暂停指定 Teradata Vantage Cloud Lake 计算集群的 Teradata 计算集群操作符。

模块内容

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator(query_strategy=None, compute_map=None, compute_attribute=None, **kwargs)[source]

基类: _TeradataComputeClusterOperator

使用指定的计算组名称和计算配置文件名称创建新的计算集群。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：TeradataComputeClusterProvisionOperator

参数：

  • compute_profile_name – 要管理的计算配置文件的名称。

  • compute_group_name – 计算配置文件所属的计算组的名称。

  • query_strategy (str | None) – 要使用的查询策略。指代 Teradata 优化器在 Teradata 计算集群中高效执行 SQL 查询的方法或方式。有效的 query_strategy 值是 ‘STANDARD’ 或 ‘ANALYTIC’。数据库级别的默认值是 STANDARD。

  • compute_map (str | None) – 计算映射的 ComputeMapName。计算集群配置文件中的 compute_map 指的是将计算资源映射到集群内的特定节点或节点集。

  • compute_attribute (str | None) – 计算配置文件的可选属性。示例计算属性 MIN_COMPUTE_COUNT(1) MAX_COMPUTE_COUNT(5) INITIALLY_SUSPENDED(‘FALSE’)

  • teradata_conn_id – 指向特定 Teradata 数据库的 Teradata 连接 ID 引用。

  • timeout – 任务超时并失败前经过的时间。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'query_strategy', 'compute_map',...[source]
ui_color = '#e07c24'[source]
query_strategy = None[source]
compute_map = None[source]
compute_attribute : str | None = None[source]
execute(context)[source]

启动 CREATE COMPUTE SQL 语句的执行。

启动在 Teradata Vantage Lake 中配置计算集群的 SQL 语句的执行，有效地创建了计算集群。Airflow 在 worker 上运行此方法并使用 trigger 进行延迟。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator(delete_compute_group=False, **kwargs)[source]

基类: _TeradataComputeClusterOperator

删除使用指定的计算组名称和计算配置文件名称创建的计算集群。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：TeradataComputeClusterDecommissionOperator

参数：

  • compute_profile_name – 要管理的计算配置文件的名称。

  • compute_group_name – 计算配置文件所属的计算组的名称。

  • delete_compute_group (bool) – 指示是否应删除计算组。设置为 True 时，表示系统应移除指定的计算组。相反，设置为 False 时，不对此计算组执行任何操作。

  • teradata_conn_id – 指向特定 Teradata 数据库的 Teradata 连接 ID 引用。

  • timeout – 任务超时并失败前经过的时间。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'delete_compute_group', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
delete_compute_group = False[source]
execute(context)[source]

启动 DROP COMPUTE SQL 语句的执行。

启动在 Teradata Vantage Lake 中解除计算集群配置的 SQL 语句的执行，有效地删除了计算集群。Airflow 在 worker 上运行此方法并使用 trigger 进行延迟。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator(**kwargs)[source]

基类: _TeradataComputeClusterOperator

用于恢复指定 Teradata Vantage Cloud Lake 计算集群的 Teradata 计算集群操作符。

通过在 Teradata Vantage Lake 计算集群 SQL 接口中使用 RESUME SQL 语句来恢复 Teradata Vantage Lake 计算集群。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：TeradataComputeClusterResumeOperator

参数：

  • compute_profile_name – 要管理的计算配置文件的名称。

  • compute_group_name – 计算配置文件所属的计算组的名称。

  • teradata_conn_id – 指向特定 Teradata 数据库的 Teradata 连接 ID 引用。

  • timeout – 任务超时并失败前经过的时间。时间单位为分钟。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
execute(context)[source]

启动 RESUME COMPUTE SQL 语句的执行。

启动在 Teradata Vantage Lake 中恢复计算集群的 SQL 语句的执行，有效地恢复了计算集群。Airflow 在 worker 上运行此方法并使用 trigger 进行延迟。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator(**kwargs)[source]

基类: _TeradataComputeClusterOperator

用于暂停指定 Teradata Vantage Cloud Lake 计算集群的 Teradata 计算集群操作符。

通过在 Teradata Vantage Lake 计算集群 SQL 接口中使用 SUSPEND SQL 语句来暂停 Teradata Vantage Lake 计算集群。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：TeradataComputeClusterSuspendOperator

参数：

  • compute_profile_name – 要管理的计算配置文件的名称。

  • compute_group_name – 计算配置文件所属的计算组的名称。

  • teradata_conn_id – 指向特定 Teradata 数据库的 Teradata 连接 ID 引用。

  • timeout – 任务超时并失败前经过的时间。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
execute(context)[source]

启动 SUSPEND COMPUTE SQL 语句的执行。

启动在 Teradata Vantage Lake 中暂停计算集群的 SQL 语句的执行，有效地暂停了计算集群。Airflow 在 worker 上运行此方法并使用 trigger 进行延迟。

此条目有帮助吗？