airflow.providers.teradata.operators.teradata_compute_cluster

模块内容

类

TeradataComputeClusterProvisionOperator

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

TeradataComputeClusterDecommissionOperator

删除具有指定计算组名称和计算配置文件名称的计算集群。

TeradataComputeClusterResumeOperator

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

TeradataComputeClusterSuspendOperator

Teradata 计算集群操作符，用于暂停指定的 Teradata Vantage Cloud Lake 计算集群。
class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator(query_strategy=None, compute_map=None, compute_attribute=None, **kwargs)[源]

基类：_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',...[源]
ui_color = '#e07c24'[源]
execute(context)[源]

启动 CREATE COMPUTE SQL 语句的执行。

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

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

基类：_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')[源]
ui_color = '#e07c24'[源]
execute(context)[源]

启动 DROP COMPUTE SQL 语句的执行。

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

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

基类：_TeradataComputeClusterOperator

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

通过在 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 语句的执行。

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

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

基类：_TeradataComputeClusterOperator

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

通过在 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 语句的执行。

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

此条目是否有帮助？