AWS：如何在Python / Boto3中以编程方式创建RDS Aurora集群

Question

我的应用程序托管在Amazon Web Services上，我开始编写应用程序所有基础结构（VPC，安全组，Beanstalk等...）的脚本。我没有找到创建RDS Aurora群集的正确方法，并且无法通过Boto3在Python中重现RDS向导（帮助您创建数据库实例和群集）。也许我缺乏基础架构和网络方面的知识，但是我认为创建Aurora集群必须是我可以访问的。

所以这是我的问题：让我们说我有一个VPC ID，一个安全组ID和一些数据库信息（用户，密码...），创建集群并使它可被我的应用程序使用的最少API调用是什么？该过程必须以集群读取器/写入器端点和仅读取器端点结尾。

Answer 1

这是我在Python / BOTO3中创建Aurora MySQL实例的方式。您必须自己实现一些缺少的功能。

def create_aurora(
    instance_identifier, # used for instance name and cluster name
    db_username,
    db_password,
    db_name,
    db_port,
    vpc_id,
    vpc_sg, # Must be an array
    dbsubnetgroup_name,
    public_access = False,
    AZ = None,
    instance_type = "db.t2.small",
    multi_az = True,
    nb_instance = 1,
    extratags = []
):
    rds = boto3.client('rds')
    # Assume a DB SUBNET Groups exists before creating the cluster. You must have created a DBSUbnetGroup associated to the Subnet of the VPC of your cluster. AWS will find it automatically.

    # 
    # Search if the cluster exists
    try:    
        db_cluster = rds.describe_db_clusters(
            DBClusterIdentifier = instance_identifier
        )['DBClusters']    
        db_cluster = db_cluster[0]
    except botocore.exceptions.ClientError   as e:
        psa.printf("Creating empty cluster\r\n");
        res = rds.create_db_cluster(
            DBClusterIdentifier = instance_identifier,
            Engine="aurora",
            MasterUsername=db_username,
            MasterUserPassword=db_password,
            DBSubnetGroupName=dbsubnetgroup_name,
            VpcSecurityGroupIds=vpc_sg,
            AvailabilityZones=AZ
        )
        db_cluster = res['DBCluster']


    cluster_name = db_cluster['DBClusterIdentifier']
    instance_identifier = db_cluster['DBClusterIdentifier']
    psa.printf("Cluster identifier : %s, status : %s, members : %d\n", instance_identifier , db_cluster['Status'], len(db_cluster['DBClusterMembers']))
    if (db_cluster['Status'] == 'deleting'):
        psa.printf(" Please wait for the cluster to be deleted and try again.\n")
        return None
    psa.printf("   Writer Endpoint : %s\n", db_cluster['Endpoint'])
    psa.printf("   Reader Endpoint : %s\n", db_cluster['ReaderEndpoint'])
    # Now create instances
    # Loop on requested number of instance, and balance them on AZ
    for i in range(1, nb_instance+1):
        if AZ != None:
            the_AZ = AZ[i -1 % len(AZ)]
            dbinstance_id = instance_identifier+"-"+str(i)+"-"+the_AZ
        else:
            the_AZ = None
            dbinstance_id = instance_identifier+"-"+str(i)
        psa.printf("Creating instance %d named '%s' in AZ %s\n", i, dbinstance_id, the_AZ)

        try:
            res = rds.create_db_instance(
                DBInstanceIdentifier=dbinstance_id,
                DBInstanceClass=instance_type,
                Engine='aurora',
                PubliclyAccessible=False,
                AvailabilityZone=the_AZ,
                DBSubnetGroupName=dbsubnetgroup_name,
                DBClusterIdentifier=instance_identifier,
                Tags = psa.tagsKeyValueToAWStags(extratags)
            )['DBInstance']
            psa.printf(" DbiResourceId=%s\n", res['DbiResourceId'])

        except botocore.exceptions.ClientError   as e:
            psa.printf(" Instance seems to exists.\n")
            res = rds.describe_db_instances(DBInstanceIdentifier = dbinstance_id)['DBInstances']
            psa.printf(" Status is %s\n", res[0]['DBInstanceStatus'])
    return db_cluster

Answer 2

是的，您在正确的轨道上。这是用于创建Aurora RDS群集的boto3 document。

此外，要解决更大的问题（即，以代码形式管理整个基础架构，您应该查看Terraform之类的选项。

[检查他们的Git回购Terraform Git Repo，因此，您可以使用此template完成使用terraform创建Aurora集群的相同任务