Cloud Function写入Cloud SQL报错‘无法处理请求’求助

静态网站托管在Cloud CDN，通过POST请求将数据发送到Cloud Function，再由Cloud Function写入仅配置私有网络访问的Cloud SQL。点击提交按钮时出现错误：Error: Could not handle the request。已启用Serverless VPC Access，且同一VPC内的VM可正常连接Cloud SQL。

相关代码 #

HTML文件

<!DOCTYPE html>
<html>
<head>
    <title>My App</title>
</head>
<body>
    <form method="post" action="<cloudfunction_link>">
        <label for="name">Name:</label>
        <input type="text" id="name" name="name"><br><br>
        <label for="email">Email:</label>
        <input type="email" id="email" name="email"><br><br>
        <input type="submit" value="Submit">
    </form>
</body>
</html>

Cloud Function Python代码

import mysql.connector
from flask import Flask, request

app = Flask(__name__)

@app.route('/', methods=['POST'])
def handle_form_submission():
    # Connect to the Cloud SQL instance
    cnx = mysql.connector.connect(user='root', password='',
                                  host='<Cloud SQL ip>',
                                  database='myapp')

    # Parse the form data
    name = request.form['name']
    email = request.form['email']

    # Insert the form data into the database
    cursor = cnx.cursor()
    insert_query = "INSERT INTO users (name, email) VALUES (%s, %s)"
    data = (name, email)
    cursor.execute(insert_query, data)
    cnx.commit()

    # Close the database connection
    cursor.close()
    cnx.close()

    return 'Form data submitted successfully'

if __name__ == '__main__':
    app.run()

排查与修复方案 #

1. 验证Cloud Function的VPC关联配置 #

• 进入Cloud Function配置页，确认已选择正确的VPC网络和Serverless VPC Access连接器
• 检查连接器的IP段，确保不与Cloud SQL私有IP范围冲突，且已授权访问Cloud SQL所在子网

2. 添加错误捕获与日志排查 #

原代码无异常处理，任何环节出错都会直接触发500错误。修改代码添加捕获逻辑，同时通过Cloud Function日志（控制台→Cloud Functions→对应函数→日志）定位具体错误：

import mysql.connector
from flask import Flask, request

app = Flask(__name__)

@app.route('/', methods=['POST'])
def handle_form_submission():
    try:
        # 连接Cloud SQL（注意使用私有IP）
        cnx = mysql.connector.connect(
            user='root',
            password='',
            host='<Cloud SQL私有IP>',
            database='myapp'
        )

        # 安全解析表单数据，避免键缺失报错
        name = request.form.get('name')
        email = request.form.get('email')
        if not name or not email:
            return '缺少必填字段', 400

        # 插入数据
        cursor = cnx.cursor()
        insert_query = "INSERT INTO users (name, email) VALUES (%s, %s)"
        data = (name, email)
        cursor.execute(insert_query, data)
        cnx.commit()

        # 关闭连接
        cursor.close()
        cnx.close()

        return '表单数据提交成功'
    except Exception as e:
        # 打印错误到日志便于排查
        print(f"错误详情: {str(e)}")
        return '提交失败，请稍后重试', 500

if __name__ == '__main__':
    app.run()

3. 检查Cloud SQL访问权限 #

• 确认使用Cloud SQL的私有IP，而非公网IP
• 验证root用户权限：允许从Serverless VPC连接器的IP段访问（可临时设置为%测试，生产环境需限制具体IP范围）
• 确认myapp数据库和users表已存在，表结构包含name和email字段

4. 处理跨域问题（若存在） #

若静态站域名与Cloud Function域名不同，需配置CORS：

1. 在requirements.txt中添加依赖：flask-cors==4.0.0
2. 修改代码启用CORS：

from flask_cors import CORS
CORS(app)

5. 确认请求格式 #

表单默认Content-Type为application/x-www-form-urlencoded，request.form可正常解析。若仍有问题，可在代码中打印request.headers和request.data到日志，确认请求格式是否正确。

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