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 }}",
    )