在函数计算中,不同的执行环境实例之间的状态是不共享的,通过数据库可以将结构化的数据持久化以实现状态共享。通过函数计算访问云上数据库,您可以进行数据查询和数据插入等操作。本文以Python函数为例,介绍如何同VPC或跨VPC跨地域访问云数据库 RDS MySQL 版。
前提条件
本文中index.py示例代码中的逻辑是查询名为users的数据库表中的所有数据,您可以根据实际情况修改表名,并确保表内至少有一条数据。
操作步骤
步骤一:设置数据库白名单
如果您选择访问同VPC内数据库的场景,请确保数据库实例与函数处于同一地域。建议您在函数计算支持的可用区创建数据库实例。更多信息,请参见函数计算支持的可用区。如果您的数据库实例不在函数计算支持的可用区内,可以通过在您的VPC环境中创建一个与函数计算相同可用区的vSwitch,并在函数的VPC配置中设置此vSwitch ID。由于同一VPC内不同vSwitch之间私网互通,因此函数计算可以通过该vSwitch访问在其他可用区的VPC内的资源。具体步骤,请参见遇到vSwitch is in unsupported zone的错误怎么办?。
登录函数计算控制台,创建Python Web函数,为函数开通VPC访问能力,并配置目标VPC资源。
请确保为函数配置的VPC与数据库实例绑定的VPC相同。
在函数详情页,依次选择
,然后在网络页面获取函数配置中的交换机网段。将上一步获取的函数配置中交换机的网段添加到数据库访问白名单。
请使用设置IP地址白名单方式授权函数访问数据库,请勿使用安全组方式。否则,可能导致函数偶尔连接不上数据库的情况,影响业务正常运行。
完成配置后,函数可以通过数据库内网地址访问RDS数据库。
不同VPC和不同地域之间属于完全的逻辑隔离,常规情况下不能跨VPC和跨地域访问数据库。如果需要跨VPC或跨地域访问数据库,可以通过为函数配置固定公网IP的方式,此时系统会在函数绑定的专有网络VPC内创建公网NAT网关,通过公网网关即可实现通过公网IP访问数据库。
在函数详情页,依次选择
,在网络面板,为函数配置固定公网IP,然后单击部署。在弹出的固定公网IP配置对话框,勾选提示框,然后单击确定。配置完成后,将参数允许函数默认网卡访问公网设置为否,使配置的固定公网IP生效。
在函数详情页,依次选择
,然后在网络页面获取函数配置的固定公网IP地址。将上一步获取的函数固定公网IP地址添加到数据库访问白名单。
请使用设置IP地址白名单方式授权函数访问数据库,请勿使用安全组方式。否则,可能导致函数偶尔连接不上数据库的情况,影响业务正常运行。
完成配置后,函数可以通过数据库公网地址访问RDS数据库。
步骤二:在函数中访问RDS
登录函数计算控制台,在函数列表找到目标函数,在函数详情页,单击代码页签,在代码编辑器编写如下示例代码。
from flask import Flask, jsonify import pymysql import os from datetime import datetime import logging app = Flask(__name__) # 全局变量用于存储 MySQL 单例连接 _mysql_connection = None # 创建数据库连接(单例模式) def getConnection(): global _mysql_connection try: # 如果连接已经存在且未断开,直接返回 if _mysql_connection is not None: try: # 测试连接是否有效(简单命令测试) with _mysql_connection.cursor() as cursor: cursor.execute("SELECT 1") # 简单查询测试连接状态 result = cursor.fetchone() if result and result[0] == 1: return _mysql_connection except pymysql.OperationalError: # 如果连接断开,重置连接 _mysql_connection = None # 如果连接不存在或已断开,重新创建连接 _mysql_connection = pymysql.connect( host=os.environ['MYSQL_HOST'], port=int(os.environ['MYSQL_PORT']), user=os.environ['MYSQL_USER'], password=os.environ['MYSQL_PASSWORD'], db=os.environ['MYSQL_DBNAME'] ) return _mysql_connection except Exception as e: logging.error(f"Error occurred during database connection: {e}") raise @app.route('/', defaults={'path': ''}) @app.route('/<path:path>', methods=['GET', 'POST', 'PUT', 'DELETE']) def hello_world(path): conn = getConnection() try: with conn.cursor() as cursor: # 查询 users 表的所有记录,users 表需要根据实际表名进行修改 sql = "SELECT * FROM users" cursor.execute(sql) result = cursor.fetchall() columns = [desc[0] for desc in cursor.description] # 获取字段名列表 # 将查询结果转换为字典列表 users = [] for row in result: user = {} for idx, column_name in enumerate(columns): value = row[idx] if isinstance(value, datetime): # 处理日期类型字段 user[column_name] = value.strftime('%Y-%m-%d %H:%M:%S') else: user[column_name] = value users.append(user) if users: # 返回所有用户的 JSON 响应 return jsonify(users), 200 else: # 如果没有找到用户,返回 404 错误 return jsonify({'error': 'No users found'}), 404 except Exception as e: logging.error(f"Error occurred during database operation: {e}") return jsonify({'error': 'Database error'}), 500 if __name__ == '__main__': app.run(host='0.0.0.0', port=9000)
在函数详情页,依次选择
,单击编辑,在环境变量面板配置以下环境变量。环境变量名称
环境变量值
说明
环境变量名称
环境变量值
说明
MYSQL_HOST
rm-bp19u8e76ae****.mysql.rds.aliyuncs.com
数据库实例的访问地址。
如果您选择同VPC内的RDS数据库的场景,请将此环境变量值设置为数据库的内网地址。
如果您选择跨VPC或跨地域访问RDS数据库的场景,请将此环境变量值设置为数据库的外网地址。
在RDS实例列表,单击目标RDS实例ID,然后在左侧导航栏,选择数据库连接,在数据库连接页面获取数据库的内网地址或外网地址。
MYSQL_DBNAME
db_test
RDS实例中创建的数据库名称。
MYSQL_PASSWORD
*****
数据库密码。
MYSQL_PORT
3306
数据库实例的私网端口。
MYSQL_USER
dms_user_****
RDS实例中创建的账号名称。
在函数详情页,选择代码页签,单击测试函数,执行成功后查看返回结果,已成功完成查询表格操作。
更多信息
更多访问RDS MySQL数据库的示例,请参见函数计算Python访问MySQL数据库。
如果您的数据库访问失败,需要根据问题现象进行排查,详情请参见数据库访问失败的常见原因。
RDS支持MySQL、SQL Server、PostgreSQL和MariaDB引擎。更多信息,请参见云数据库RDS简介。
如果您希望使用Serverless Devs命令行工具创建函数并访问RDS MySQL数据库,请参见以下步骤。
- 本页导读 (1)
- 前提条件
- 操作步骤
- 步骤一:设置数据库白名单
- 步骤二:在函数中访问RDS
- 更多信息