TeradataComputeClusterProvisionOperator¶

TeradataComputeClusterProvisionOperator 的目的是配置新的 Teradata Vantage Cloud Lake 计算集群，并指定计算组名和计算配置文件名。使用 TeradataComputeClusterProvisionOperator 在 Teradata Vantage Cloud Lake 中配置新的计算集群。

在 Teradata Vantage Cloud Lake 中使用 TeradataComputeClusterProvisionOperator 配置新计算集群的示例如下：

tests/system/teradata/example_teradata_compute_cluster.py

    compute_cluster_provision_operation = TeradataComputeClusterProvisionOperator(
        task_id="compute_cluster_provision_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
        query_strategy="{{ params.query_strategy }}",
        compute_map="{{ params.compute_map }}",
        compute_attribute="{{ params.compute_attribute }}",
    )

TeradataComputeClusterDecommissionOperator¶

TeradataComputeClusterDecommissionOperator 的目的是解除指定 Teradata Vantage Cloud Lake 计算集群的配置。使用 TeradataComputeClusterProvisionOperator 解除指定 Teradata Vantage Cloud Lake 计算集群的配置。

使用 TeradataComputeClusterDecommissionOperator 解除指定 Teradata Vantage Cloud Lake 计算集群配置的示例如下：

tests/system/teradata/example_teradata_compute_cluster.py

    compute_cluster_decommission_operation = TeradataComputeClusterDecommissionOperator(
        task_id="compute_cluster_decommission_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        delete_compute_group=bool("{{ params.delete_compute_group }}"),
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )

TeradataComputeClusterResumeOperator¶

TeradataComputeClusterResumeOperator 的目的是启动指定计算组名和计算配置文件名的 Teradata Vantage Cloud Lake 计算集群。使用 TeradataComputeClusterResumeOperator 在 Teradata Vantage Cloud Lake 中启动指定的计算集群。

使用 TeradataComputeClusterSuspendOperator 启动指定 Teradata Vantage Cloud Lake 计算集群的示例如下：

tests/system/teradata/example_teradata_compute_cluster.py

    compute_cluster_resume_operation = TeradataComputeClusterResumeOperator(
        task_id="compute_cluster_resume_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )

TeradataComputeClusterSuspendOperator¶

TeradataComputeClusterSuspendOperator 的目的是暂停指定计算组名和计算配置文件名的 Teradata Vantage Cloud Lake 计算集群。使用 TeradataComputeClusterSuspendOperator 在 Teradata Vantage Cloud Lake 中暂停指定的计算集群。

使用 TeradataComputeClusterSuspendOperator 暂停指定 Teradata Vantage Cloud Lake 计算集群的示例如下：

tests/system/teradata/example_teradata_compute_cluster.py

    compute_cluster_suspend_operation = TeradataComputeClusterSuspendOperator(
        task_id="compute_cluster_suspend_operation",
        compute_profile_name="{{ params.compute_profile_name }}",
        compute_group_name="{{ params.compute_group_name }}",
        teradata_conn_id="{{ params.teradata_conn_id }}",
        timeout="{{ params.timeout }}",
    )