Google Cloud AlloyDB Operators¶

AlloyDB for PostgreSQL 是一個完全託管的、相容 PostgreSQL 的資料庫服務，旨在滿足您最苛刻的工作負載需求，包括混合事務處理和分析處理。AlloyDB 將 Google 構建的資料庫引擎與基於雲的多節點架構相結合，以提供企業級效能、可靠性和可用性。

Airflow 提供了用於管理 AlloyDB 叢集的 Operator。

準備工作¶

要使用這些 Operator，您必須完成以下幾步

使用 Cloud 控制檯選擇或建立一個 Cloud Platform 專案。

為您的專案啟用結算，詳見 Google Cloud 文件。

啟用 API，詳見 Cloud 控制檯文件。
透過 pip 安裝 API 庫。
pip install 'apache-airflow[google]'
有關安裝的詳細資訊，請參閱。
設定 Google Cloud 連線.

建立叢集¶

要建立 AlloyDB 叢集（主例項和輔助例項），您可以使用 AlloyDBCreateClusterOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

create_cluster = AlloyDBCreateClusterOperator(
    task_id="create_cluster",
    cluster_id=CLUSTER_ID,
    cluster_configuration=CLUSTER,
    is_secondary=False,
    location=GCP_LOCATION,
    project_id=GCP_PROJECT_ID,
)

更新叢集¶

要更新 AlloyDB 叢集，您可以使用 AlloyDBUpdateClusterOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

update_cluster = AlloyDBUpdateClusterOperator(
    task_id="update_cluster",
    cluster_id=CLUSTER_ID,
    cluster_configuration=CLUSTER_UPDATE,
    update_mask=CLUSTER_UPDATE_MASK,
    location=GCP_LOCATION,
    project_id=GCP_PROJECT_ID,
)

刪除叢集¶

要刪除 AlloyDB 叢集，您可以使用 AlloyDBDeleteClusterOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

delete_cluster = AlloyDBDeleteClusterOperator(
    task_id="delete_cluster",
    project_id=GCP_PROJECT_ID,
    location=GCP_LOCATION,
    cluster_id=CLUSTER_ID,
)

建立例項¶

要建立 AlloyDB 例項（主例項和輔助例項），您可以使用 AlloyDBCreateInstanceOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

create_instance = AlloyDBCreateInstanceOperator(
    task_id="create_instance",
    cluster_id=CLUSTER_ID,
    instance_id=INSTANCE_ID,
    instance_configuration=INSTANCE,
    is_secondary=False,
    project_id=GCP_PROJECT_ID,
    location=GCP_LOCATION,
)

更新例項¶

要更新 AlloyDB 例項，您可以使用 AlloyDBUpdateInstanceOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

update_instance = AlloyDBUpdateInstanceOperator(
    task_id="update_instance",
    cluster_id=CLUSTER_ID,
    instance_id=INSTANCE_ID,
    instance_configuration=INSTANCE_UPDATE,
    update_mask=INSTANCE_UPDATE_MASK,
    location=GCP_LOCATION,
    project_id=GCP_PROJECT_ID,
)

刪除例項¶

要刪除 AlloyDB 例項，您可以使用 AlloyDBDeleteInstanceOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

delete_instance = AlloyDBDeleteInstanceOperator(
    task_id="delete_instance",
    cluster_id=CLUSTER_ID,
    instance_id=INSTANCE_ID,
    project_id=GCP_PROJECT_ID,
    location=GCP_LOCATION,
)

建立使用者¶

要建立 AlloyDB 使用者，您可以使用 AlloyDBCreateUserOperator。請注意，必須先在叢集中建立主例項。

tests/system/google/cloud/alloy_db/example_alloy_db.py

creat_user = AlloyDBCreateUserOperator(
    task_id="create_user",
    user_id=USER_ID,
    user_configuration=USER,
    cluster_id=CLUSTER_ID,
    project_id=GCP_PROJECT_ID,
    location=GCP_LOCATION,
)

更新使用者¶

要更新 AlloyDB 使用者，您可以使用 AlloyDBUpdateUserOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

update_user = AlloyDBUpdateUserOperator(
    task_id="update_user",
    user_id=USER_ID,
    user_configuration=USER_UPDATE,
    cluster_id=CLUSTER_ID,
    update_mask=USER_UPDATE_MASK,
    location=GCP_LOCATION,
    project_id=GCP_PROJECT_ID,
)

刪除使用者¶

要刪除 AlloyDB 使用者，您可以使用 AlloyDBDeleteUserOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

delete_user = AlloyDBDeleteUserOperator(
    task_id="delete_user",
    cluster_id=CLUSTER_ID,
    user_id=USER_ID,
    project_id=GCP_PROJECT_ID,
    location=GCP_LOCATION,
)

建立備份¶

要建立 AlloyDB 備份，您可以使用 AlloyDBCreateBackupOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

create_backup = AlloyDBCreateBackupOperator(
    task_id="create_backup",
    backup_id=BACKUP_ID,
    backup_configuration=BACKUP,
    location=GCP_LOCATION_BACKUP,
    project_id=GCP_PROJECT_ID,
)

更新備份¶

要更新 AlloyDB 備份，您可以使用 AlloyDBUpdateBackupOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

update_backup = AlloyDBUpdateBackupOperator(
    task_id="update_backup",
    backup_id=BACKUP_ID,
    backup_configuration=BACKUP_UPDATE,
    update_mask=BACKUP_UPDATE_MASK,
    location=GCP_LOCATION_BACKUP,
    project_id=GCP_PROJECT_ID,
)

刪除備份¶

要刪除 AlloyDB 備份，您可以使用 AlloyDBDeleteBackupOperator。

tests/system/google/cloud/alloy_db/example_alloy_db.py

delete_backup = AlloyDBDeleteBackupOperator(
    task_id="delete_backup",
    backup_id=BACKUP_ID,
    location=GCP_LOCATION_BACKUP,
    project_id=GCP_PROJECT_ID,
)

此條目有幫助嗎？