airflow.providers.teradata.operators.teradata_compute_cluster¶
Module Contents¶
Classes¶
Creates the new Computer Cluster with specified Compute Group Name and Compute Profile Name. |
|
Drops the compute cluster with specified Compute Group Name and Compute Profile Name. |
|
Teradata Compute Cluster Operator to Resume the specified Teradata Vantage Cloud Lake Compute Cluster. |
|
Teradata Compute Cluster Operator to suspend the specified Teradata Vantage Cloud Lake Compute Cluster. |
- class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator(query_strategy=None, compute_map=None, compute_attribute=None, **kwargs)[source]¶
Bases:
_TeradataComputeClusterOperatorCreates the new Computer Cluster with specified Compute Group Name and Compute Profile Name.
See also
For more information on how to use this operator, take a look at the guide: TeradataComputeClusterProvisionOperator
- Parameters
compute_profile_name – Name of the Compute Profile to manage.
compute_group_name – Name of compute group to which compute profile belongs.
query_strategy (str | None) – Query strategy to use. Refers to the approach or method used by the Teradata Optimizer to execute SQL queries efficiently within a Teradata computer cluster. Valid query_strategy value is either ‘STANDARD’ or ‘ANALYTIC’. Default at database level is STANDARD.
compute_map (str | None) – ComputeMapName of the compute map. The compute_map in a compute cluster profile refers to the mapping of compute resources to a specific node or set of nodes within the cluster.
compute_attribute (str | None) – Optional attributes of compute profile. Example compute attribute MIN_COMPUTE_COUNT(1) MAX_COMPUTE_COUNT(5) INITIALLY_SUSPENDED(‘FALSE’)
teradata_conn_id – The Teradata connection id reference to a specific Teradata database.
timeout – Time elapsed before the task times out and fails.
- template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'query_strategy', 'compute_map',...[source]¶
- execute(context)[source]¶
Initiate the execution of CREATE COMPUTE SQL statement.
Initiate the execution of the SQL statement for provisioning the compute cluster within Teradata Vantage Lake, effectively creates the compute cluster. Airflow runs this method on the worker and defers using the trigger.
- class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator(delete_compute_group=False, **kwargs)[source]¶
Bases:
_TeradataComputeClusterOperatorDrops the compute cluster with specified Compute Group Name and Compute Profile Name.
See also
For more information on how to use this operator, take a look at the guide: TeradataComputeClusterDecommissionOperator
- Parameters
compute_profile_name – Name of the Compute Profile to manage.
compute_group_name – Name of compute group to which compute profile belongs.
delete_compute_group (bool) – Indicates whether the compute group should be deleted. When set to True, it signals the system to remove the specified compute group. Conversely, when set to False, no action is taken on the compute group.
teradata_conn_id – The Teradata connection id reference to a specific Teradata database.
timeout – Time elapsed before the task times out and fails.
- template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'delete_compute_group', 'teradata_conn_id', 'timeout')[source]¶
- execute(context)[source]¶
Initiate the execution of DROP COMPUTE SQL statement.
Initiate the execution of the SQL statement for decommissioning the compute cluster within Teradata Vantage Lake, effectively drops the compute cluster. Airflow runs this method on the worker and defers using the trigger.
- class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator(**kwargs)[source]¶
Bases:
_TeradataComputeClusterOperatorTeradata Compute Cluster Operator to Resume the specified Teradata Vantage Cloud Lake Compute Cluster.
Resumes the Teradata Vantage Lake Computer Cluster by employing the RESUME SQL statement within the Teradata Vantage Lake Compute Cluster SQL Interface.
See also
For more information on how to use this operator, take a look at the guide: TeradataComputeClusterResumeOperator
- Parameters
compute_profile_name – Name of the Compute Profile to manage.
compute_group_name – Name of compute group to which compute profile belongs.
teradata_conn_id – The Teradata connection id reference to a specific Teradata database.
timeout – Time elapsed before the task times out and fails. Time is in minutes.
- template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]¶
- class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator(**kwargs)[source]¶
Bases:
_TeradataComputeClusterOperatorTeradata Compute Cluster Operator to suspend the specified Teradata Vantage Cloud Lake Compute Cluster.
Suspends the Teradata Vantage Lake Computer Cluster by employing the SUSPEND SQL statement within the Teradata Vantage Lake Compute Cluster SQL Interface.
See also
For more information on how to use this operator, take a look at the guide: TeradataComputeClusterSuspendOperator
- Parameters
compute_profile_name – Name of the Compute Profile to manage.
compute_group_name – Name of compute group to which compute profile belongs.
teradata_conn_id – The Teradata connection id reference to a specific Teradata database.
timeout – Time elapsed before the task times out and fails.
- template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]¶
- execute(context)[source]¶
Initiate the execution of SUSPEND COMPUTE SQL statement.
Initiate the execution of the SQL statement for suspending the compute cluster within Teradata Vantage Lake, effectively suspends the compute cluster. Airflow runs this method on the worker and defers using the trigger.