从 Google 云函数 python3.7 连接到 Google 云 SQL

Question

我正在尝试使用 pymysql 进行连接，使用的代码非常接近文档中提供的示例：https://cloud.google.com/functions/docs/sql#functions_sql_mysql-python

数据库有 public ip，没有授权网络（因为 cf 应该使用套接字），我创建的用户允许从任何地方访问。

运行在本地使用云 SQL 代理工作正常，但在 Google 云上我连接被拒绝。

编辑：使用环境变量

在本地将代码更新为运行

import logging
import os

import pymysql
from pymysql.err import OperationalError


mysql_conn = None


def __get_cursor():
    try:
        return mysql_conn.cursor()
    except OperationalError:
        mysql_conn.ping(reconnect=True)
        return mysql_conn.cursor()


def get_config():
    return {
        'unix_socket': f'/cloudsql/{os.environ["CONNECTION_NAME"]}',
        'user': os.environ['DB_USER'],
        'password': os.environ['DB_PASSWORD'],
        'db': os.environ['DB_NAME'],
        'charset': 'utf8mb4',
        'cursorclass': pymysql.cursors.DictCursor,
        'autocommit': True
    }


def mysql_demo(request):
    global mysql_conn

    if not mysql_conn:
        mysql_config = get_config()
        logging.info('Open db with config: %s', mysql_config)

        try:
            mysql_conn = pymysql.connect(**mysql_config)
        except OperationalError as exception:
            logging.warning('Unable to get db connection: %s', str(exception))
            return

    with __get_cursor() as cursor:
        cursor.execute('SELECT NOW() as now')
        results = cursor.fetchone()
        return str(results['now'])


if __name__ == '__main__':
    logging.basicConfig(level=logging.INFO)
    os.environ['CONNECTION_NAME'] = 'my-project:us-central1:cf-test'
    os.environ['DB_USER'] = 'db-user'
    os.environ['DB_PASSWORD'] = 'db-password'
    os.environ['DB_NAME'] = 'db_name'
    logging.info(mysql_demo(None))

编辑：附加输出

在本地运行ning 时，打印出：

INFO:root:2019-09-24 07:11:54

当运行ning 作为云函数时，我得到输出：`

2019-09-24 09:14:59.279 CEST test-cloud-sql mesuju89uxuw Open db with config: {'unix_socket': '/cloudsql/boeingfda-jal:us-central1:cf-test', 'user': 'enplore', 'password': 'az2labha', 'db': 'content_enplore_auth', 'charset': 'utf8mb4', 'cursorclass': <class 'pymysql.cursors.DictCursor'>, 'autocommit': True}
2019-09-24 09:14:59.856 CEST test-cloud-sql mesuju89uxuw Unable to get db connection: (2003, "Can't connect to MySQL server on 'localhost' ([Errno 111] Connection refused)")

Answer 1

如果您 post 您收到的错误通常会更有帮助，因为它通常会提供额外的上下文。以下是一些可能的原因：

确保云 SQL 管理员 API 已启用。
验证您使用的服务帐户（默认为 service-[YOUR_PROJECT_NUMBER]@gcf-admin-robot.iam.gserviceaccount.com）运行实例具有正确的 IAM 权限（Cloud SQL Client 角色或 cloudsql.instances.connect 和 cloudsql.instances.get权限）。
最后，确认 CONNECTION_NAME 变量没有拼错。

最后，您应该考虑使用连接池（如 SQLAlchemy）并将最大限制设置为 1。连接池将更优雅地处理错误，并限制每个实例使用的连接数。

Answer 2

您的 unix_socket 条目似乎未正确生成。它接受以下格式的数据：

'/cloudsql/project-id:region:instance-name'

示例：

'/cloudsql/my-awesome-project:us-central1:mysqlinst1'

要获取准确的连接名称，您可以使用以下命令：

gcloud sql instances describe <instance_name> | grep connectionName

从 Google 云函数 python3.7 连接到 Google 云 SQL

Connecting to Google Cloud SQL from a Google Cloud Function python3.7

python

google-cloud-platform

google-cloud-functions

google-cloud-sql

pymysql