Google Cloud AlloyDB 运算符¶

AlloyDB for PostgreSQL 是一个完全托管的、与 PostgreSQL 兼容的数据库服务，专为要求最高的混合事务和分析处理工作负载而设计。 AlloyDB 将 Google 构建的数据库引擎与基于云的多节点架构相结合，以提供企业级的性能、可靠性和可用性。

Airflow 提供了用于管理 AlloyDB 集群的运算符。

先决条件任务¶

要使用这些运算符，您必须执行以下几项操作

使用 Cloud Console 选择或创建一个 Cloud Platform 项目。

按照 Google Cloud 文档中的说明，为您的项目启用结算功能。

按照 Cloud Console 文档中的说明，启用 API。
通过 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,
)