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