airflow.providers.teradata.operators.teradata_compute_cluster

模組內容

類別

TeradataComputeClusterProvisionOperator

使用指定的運算群組名稱和運算設定檔名稱建立新的運算叢集。

TeradataComputeClusterDecommissionOperator

刪除具有指定運算群組名稱和運算設定檔名稱的運算叢集。

TeradataComputeClusterResumeOperator

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

TeradataComputeClusterSuspendOperator

Teradata 運算叢集運算子，用於暫停指定的 Teradata Vantage Cloud Lake 運算叢集。
class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterProvisionOperator(query_strategy=None, compute_map=None, compute_attribute=None, **kwargs)[原始碼]

基底類別： _TeradataComputeClusterOperator

使用指定的運算群組名稱和運算設定檔名稱建立新的運算叢集。

另請參閱

如需關於如何使用此運算子的更多資訊，請查看指南： TeradataComputeClusterProvisionOperator

參數

  • compute_profile_name – 要管理的運算設定檔名稱。

  • compute_group_name – 運算設定檔所屬的運算群組名稱。

  • query_strategy (str | None) – 要使用的查詢策略。指的是 Teradata Optimizer 在 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',...[原始碼]
ui_color = '#e07c24'[原始碼]
execute(context)[原始碼]

啟動 CREATE COMPUTE SQL 陳述式的執行。

啟動 SQL 陳述式的執行，以在 Teradata Vantage Lake 中佈建運算叢集，有效地建立運算叢集。Airflow 在 worker 上執行此方法，並使用觸發器延遲執行。

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

基底類別： _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')[原始碼]
ui_color = '#e07c24'[原始碼]
execute(context)[原始碼]

啟動 DROP COMPUTE SQL 陳述式的執行。

啟動 SQL 陳述式的執行，以在 Teradata Vantage Lake 中解除運算叢集的委任，有效地刪除運算叢集。Airflow 在 worker 上執行此方法，並使用觸發器延遲執行。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterResumeOperator(**kwargs)[原始碼]

基底類別： _TeradataComputeClusterOperator

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

透過在 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')[原始碼]
ui_color = '#e07c24'[原始碼]
execute(context)[原始碼]

啟動 RESUME COMPUTE SQL 陳述式的執行。

啟動 SQL 陳述式的執行，以在 Teradata Vantage Lake 中恢復運算叢集，有效地恢復運算叢集。Airflow 在 worker 上執行此方法，並使用觸發器延遲執行。

class airflow.providers.teradata.operators.teradata_compute_cluster.TeradataComputeClusterSuspendOperator(**kwargs)[原始碼]

基底類別： _TeradataComputeClusterOperator

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

透過在 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')[原始碼]
ui_color = '#e07c24'[原始碼]
execute(context)[原始碼]

啟動 SUSPEND COMPUTE SQL 陳述式的執行。

啟動 SQL 陳述式的執行，以在 Teradata Vantage Lake 中暫停運算叢集，有效地暫停運算叢集。Airflow 在 worker 上執行此方法，並使用觸發器延遲執行。

此條目是否有幫助？