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