使用AWS SDK ExecuteSQL操作Oracle RDS遇ARN错误及替代方案咨询

1. ExecuteSQL接口是否仅支持Aurora？ #

是的，RDS Data Service的ExecuteSQL接口仅支持Aurora Serverless DB集群。从官方文档对dbClusterOrInstanceArn字段的定义可以明确看到，该字段要求传入的是Aurora Serverless集群的ARN，而非普通RDS实例（比如Oracle RDS）的ARN——这也是你传入Oracle RDS实例ARN时触发BadRequestException错误的直接原因。

2. Lambda执行Oracle RDS查询的替代方法 #

方法一：直接使用Oracle数据库驱动连接 #

在Lambda中通过Oracle官方驱动（如Python的python-oracledb、Java的Oracle JDBC驱动）直接连接Oracle RDS实例，步骤如下：

• 为Lambda配置VPC权限，确保Lambda所在安全组能访问Oracle RDS实例的安全组（开放默认端口1521）。
• 将数据库凭证（用户名、密码）存储在AWS Secrets Manager中，Lambda通过IAM权限读取凭证。
• 在Lambda层中添加对应的驱动依赖（避免直接打包过大的依赖包），编写代码建立连接并执行SQL。

示例Python代码片段：

import oracledb
import boto3
import os

def lambda_handler(event, context):
    # 从Secrets Manager获取数据库凭证
    secrets_manager = boto3.client('secretsmanager')
    secret_response = secrets_manager.get_secret_value(SecretId=os.environ['SECRET_ID'])
    secret = eval(secret_response['SecretString'])
    
    # 建立Oracle数据库连接
    connection = oracledb.connect(
        user=secret['username'],
        password=secret['password'],
        dsn=f"{os.environ['DB_HOST']}:{os.environ['DB_PORT']}/{os.environ['DB_SERVICE_NAME']}"
    )
    
    # 执行查询并获取结果
    cursor = connection.cursor()
    cursor.execute("SELECT * FROM your_target_table")
    query_results = cursor.fetchall()
    
    connection.close()
    return {"query_results": query_results}

方法二：使用AWS RDS Proxy #

通过RDS Proxy作为中间层连接Oracle RDS实例，优势在于自带连接池管理、自动故障转移，且支持IAM认证访问：

• 创建RDS Proxy并关联你的Oracle RDS实例，配置Proxy的IAM角色权限。
• Lambda通过IAM权限访问RDS Proxy，无需直接存储数据库凭证。
• 代码中连接RDS Proxy的端点而非直接连接RDS实例，其余逻辑与直接连接类似。

方法三：定时批量查询（基于EventBridge触发） #

如果是定期执行的批量查询需求，可以通过Amazon EventBridge定时触发Lambda，Lambda再通过上述两种方法执行Oracle查询，适合非实时的统计、数据同步类任务。

内容的提问来源于stack exchange，提问作者HMT