带有 Google Cloud SQL 的 Google Cloud Function：Python SQLalchemy 引擎工作，但连接失败

Question

我有一个简单的测试脚本，以确保我可以使用 GCF 连接到 Google Cloud SQL 实例并进行读/写。

def update_db(request):

    import sqlalchemy

    # connect to GCP SQL db
    user = 'root'
    pw = 'XXX'
    conn_name = 'hb-project-319121:us-east4:hb-data'
    db_name = 'Homebase'

    url = 'mysql+pymysql://{}:{}@/{}?unix_socket=/cloudsql/{}'.format(user,pw,db_name,conn_name)
    engine = sqlalchemy.create_engine(url,pool_size=1,max_overflow=0)

    # Returns
    return f'Success'

这是成功的，但是当我尝试添加连接时：

conn = engine.connect()

我收到以下错误：

pymysql.err.OperationalError: (1045, "Access denied for user 'root'@'cloudsqlproxy~' (using password: YES)")

可以创建引擎但无法与之建立连接似乎很奇怪？值得注意的是，任何类型的 execute 使用引擎，例如engine.execute('select * from table limit 3')也会导致上面的错误。

感谢任何想法。感谢您的宝贵时间

干杯， 戴夫

Answer 1

当调用create_engine 方法时，它会创建必要的对象，但实际上并不尝试连接到数据库。

Per the SQLAlchemy documentation:

[create_engine] 创建一个针对 [连接字符串中的数据库] 定制的 Dialect 对象，以及一个 Pool 对象，该对象将在连接请求时在 [host]:[port] 建立 DBAPI 连接第一次收到。

您从 MySQL 收到的错误消息可能是由于 special user account for the Cloud SQL Auth proxy 尚未创建。

您需要create a user in CloudSQL (MySQL) （'[USER_NAME]'@'cloudsqlproxy~%' 或 '[USER_NAME]'@'cloudsqlproxy~[IP_ADDRESS]'）。