airflow.providers.teradata.operators.teradata_compute_cluster

類

TeradataComputeClusterProvisionOperator

使用指定的計算組名稱和計算配置檔名稱建立新的計算叢集。

TeradataComputeClusterDecommissionOperator

刪除使用指定的計算組名稱和計算配置檔名稱建立的計算叢集。

TeradataComputeClusterResumeOperator

用於恢復指定 Teradata Vantage Cloud Lake 計算叢集的 Teradata 計算叢集運算子。

TeradataComputeClusterSuspendOperator

用於暫停指定 Teradata Vantage Cloud Lake 計算叢集的 Teradata 計算叢集運算子。

模組內容

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator(query_strategy=None, compute_map=None, compute_attribute=None, **kwargs)[source]

基類: _TeradataComputeClusterOperator

使用指定的計算組名稱和計算配置檔名稱建立新的計算叢集。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：TeradataComputeClusterProvisionOperator

引數：

  • compute_profile_name – 要管理的計算配置檔案的名稱。

  • compute_group_name – 計算配置檔案所屬的計算組的名稱。

  • query_strategy (str | None) – 要使用的查詢策略。指代 Teradata 最佳化器在 Teradata 計算叢集中高效執行 SQL 查詢的方法或方式。有效的 query_strategy 值是 ‘STANDARD’ 或 ‘ANALYTIC’。資料庫級別的預設值是 STANDARD。

  • compute_map (str | None) – 計算對映的 ComputeMapName。計算叢集配置檔案中的 compute_map 指的是將計算資源對映到叢集內的特定節點或節點集。

  • compute_attribute (str | None) – 計算配置檔案的可選屬性。示例計算屬性 MIN_COMPUTE_COUNT(1) MAX_COMPUTE_COUNT(5) INITIALLY_SUSPENDED(‘FALSE’)

  • teradata_conn_id – 指向特定 Teradata 資料庫的 Teradata 連線 ID 引用。

  • timeout – 任務超時並失敗前經過的時間。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'query_strategy', 'compute_map',...[source]
ui_color = '#e07c24'[source]
query_strategy = None[source]
compute_map = None[source]
compute_attribute : str | None = None[source]
execute(context)[source]

啟動 CREATE COMPUTE SQL 語句的執行。

啟動在 Teradata Vantage Lake 中配置計算叢集的 SQL 語句的執行，有效地建立了計算叢集。Airflow 在 worker 上執行此方法並使用 trigger 進行延遲。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterDecommissionOperator(delete_compute_group=False, **kwargs)[source]

基類: _TeradataComputeClusterOperator

刪除使用指定的計算組名稱和計算配置檔名稱建立的計算叢集。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：TeradataComputeClusterDecommissionOperator

引數：

  • compute_profile_name – 要管理的計算配置檔案的名稱。

  • compute_group_name – 計算配置檔案所屬的計算組的名稱。

  • delete_compute_group (bool) – 指示是否應刪除計算組。設定為 True 時，表示系統應移除指定的計算組。相反，設定為 False 時，不對此計算組執行任何操作。

  • teradata_conn_id – 指向特定 Teradata 資料庫的 Teradata 連線 ID 引用。

  • timeout – 任務超時並失敗前經過的時間。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'delete_compute_group', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
delete_compute_group = False[source]
execute(context)[source]

啟動 DROP COMPUTE SQL 語句的執行。

啟動在 Teradata Vantage Lake 中解除計算叢集配置的 SQL 語句的執行，有效地刪除了計算叢集。Airflow 在 worker 上執行此方法並使用 trigger 進行延遲。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator(**kwargs)[source]

基類: _TeradataComputeClusterOperator

用於恢復指定 Teradata Vantage Cloud Lake 計算叢集的 Teradata 計算叢集運算子。

透過在 Teradata Vantage Lake 計算叢集 SQL 介面中使用 RESUME SQL 語句來恢復 Teradata Vantage Lake 計算叢集。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：TeradataComputeClusterResumeOperator

引數：

  • compute_profile_name – 要管理的計算配置檔案的名稱。

  • compute_group_name – 計算配置檔案所屬的計算組的名稱。

  • teradata_conn_id – 指向特定 Teradata 資料庫的 Teradata 連線 ID 引用。

  • timeout – 任務超時並失敗前經過的時間。時間單位為分鐘。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
execute(context)[source]

啟動 RESUME COMPUTE SQL 語句的執行。

啟動在 Teradata Vantage Lake 中恢復計算叢集的 SQL 語句的執行，有效地恢復了計算叢集。Airflow 在 worker 上執行此方法並使用 trigger 進行延遲。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator(**kwargs)[source]

基類: _TeradataComputeClusterOperator

用於暫停指定 Teradata Vantage Cloud Lake 計算叢集的 Teradata 計算叢集運算子。

透過在 Teradata Vantage Lake 計算叢集 SQL 介面中使用 SUSPEND SQL 語句來暫停 Teradata Vantage Lake 計算叢集。

另請參閱

有關如何使用此運算子的更多資訊，請參閱指南：TeradataComputeClusterSuspendOperator

引數：

  • compute_profile_name – 要管理的計算配置檔案的名稱。

  • compute_group_name – 計算配置檔案所屬的計算組的名稱。

  • teradata_conn_id – 指向特定 Teradata 資料庫的 Teradata 連線 ID 引用。

  • timeout – 任務超時並失敗前經過的時間。

template_fields: collections.abc.Sequence[str] = ('compute_profile_name', 'compute_group_name', 'teradata_conn_id', 'timeout')[source]
ui_color = '#e07c24'[source]
execute(context)[source]

啟動 SUSPEND COMPUTE SQL 語句的執行。

啟動在 Teradata Vantage Lake 中暫停計算叢集的 SQL 語句的執行，有效地暫停了計算叢集。Airflow 在 worker 上執行此方法並使用 trigger 進行延遲。

此條目有幫助嗎？