如何从 Go 中的 Cloud Function 连接到 Cloud-SQL?
How to connect to Cloud-SQL from Cloud Function in Go?
对于一个项目,我正在尝试将云功能连接到云 sql 数据库设置,如 this quickstart guide 中所述。
该功能配置在同一区域,服务帐户具有角色Cloud SQL-Client
。我通过我的电脑调用这个函数是这样的:
gcloud functions call <function-name> --region=<region> --data '{"recipient":"hello","requester":"hello","message":"test"}'
与函数的连接正常,似乎只是对数据库的身份验证不起作用,但我不知道我失败的地方。
我多次检查了密码、用户和连接名称,重设了密码,但仍然没有用。
我发现问题 here 与将云功能连接到云有关 sql。
我尝试用单引号将 dsn
字符串中的密码括起来,以确保转义密码中的字符不是问题。
我还检查了进来的环境变量,它们是我在配置中输入的。
该函数只是出于测试目的对数据库执行 ping 操作:
package receiver
import (
"database/sql"
"fmt"
"net/http"
"os"
// Import Postgres SQL driver
_ "github.com/lib/pq"
)
// Receives a message and stores it
func Receive(w http.ResponseWriter, r *http.Request) {
connectionName := os.Getenv("POSTGRES_INSTANCE_CONNECTION_NAME")
dbUser := os.Getenv("POSTGRES_USER")
dbPassword := os.Getenv("POSTGRES_PASSWORD")
dsn := fmt.Sprintf("user=%s password='%s' host=/cloudsql/%s dbname=messages", dbUser, dbPassword, connectionName)
var err error
db, err := sql.Open("postgres", dsn)
if err != nil {
fmt.Fprintf(w, "Could not open db: %v \n", err)
}
// Only allow 1 connection to the database to avoid overloading
db.SetMaxIdleConns(1)
db.SetMaxOpenConns(1)
defer db.Close()
if pingerror := db.Ping(); pingerror != nil {
fmt.Fprintf(w, "Failed to ping database: %s \n", pingerror)
return
}
}
变量 POSTGRES_INSTANCE_CONNECTION_NAME
的格式如 here 所述 ProjectID:Region:InstanceID
。
预期是一条成功消息或没有错误,我实际上收到了这条消息:
pq: password authentication failed for user "postgres"
注意:我还使用我的 sql 数据库设置创建了一个包含来自 here 的演示代码的函数,错误是相同的。似乎我在设置用户或 sql 实例时错过了一些步骤。但是我找不到哪个。
/cloudsql/{connectionName}
处的 unix 套接字仅在 GCF 运行时提供。在本地 运行 时,您需要更改连接字符串或使用 Cloud SQL proxy 在同一路径上模拟 unix 套接字。
回答我自己的问题感觉很奇怪,但问题是:由于某种原因无法与 postgres
用户连接。最后我为函数创建了一个新的数据库用户和一个只包含字母数字字符的密码。
对于一个项目,我正在尝试将云功能连接到云 sql 数据库设置,如 this quickstart guide 中所述。
该功能配置在同一区域,服务帐户具有角色Cloud SQL-Client
。我通过我的电脑调用这个函数是这样的:
gcloud functions call <function-name> --region=<region> --data '{"recipient":"hello","requester":"hello","message":"test"}'
与函数的连接正常,似乎只是对数据库的身份验证不起作用,但我不知道我失败的地方。
我多次检查了密码、用户和连接名称,重设了密码,但仍然没有用。 我发现问题 here 与将云功能连接到云有关 sql。
我尝试用单引号将 dsn
字符串中的密码括起来,以确保转义密码中的字符不是问题。
我还检查了进来的环境变量,它们是我在配置中输入的。
该函数只是出于测试目的对数据库执行 ping 操作:
package receiver
import (
"database/sql"
"fmt"
"net/http"
"os"
// Import Postgres SQL driver
_ "github.com/lib/pq"
)
// Receives a message and stores it
func Receive(w http.ResponseWriter, r *http.Request) {
connectionName := os.Getenv("POSTGRES_INSTANCE_CONNECTION_NAME")
dbUser := os.Getenv("POSTGRES_USER")
dbPassword := os.Getenv("POSTGRES_PASSWORD")
dsn := fmt.Sprintf("user=%s password='%s' host=/cloudsql/%s dbname=messages", dbUser, dbPassword, connectionName)
var err error
db, err := sql.Open("postgres", dsn)
if err != nil {
fmt.Fprintf(w, "Could not open db: %v \n", err)
}
// Only allow 1 connection to the database to avoid overloading
db.SetMaxIdleConns(1)
db.SetMaxOpenConns(1)
defer db.Close()
if pingerror := db.Ping(); pingerror != nil {
fmt.Fprintf(w, "Failed to ping database: %s \n", pingerror)
return
}
}
变量 POSTGRES_INSTANCE_CONNECTION_NAME
的格式如 here 所述 ProjectID:Region:InstanceID
。
预期是一条成功消息或没有错误,我实际上收到了这条消息:
pq: password authentication failed for user "postgres"
注意:我还使用我的 sql 数据库设置创建了一个包含来自 here 的演示代码的函数,错误是相同的。似乎我在设置用户或 sql 实例时错过了一些步骤。但是我找不到哪个。
/cloudsql/{connectionName}
处的 unix 套接字仅在 GCF 运行时提供。在本地 运行 时,您需要更改连接字符串或使用 Cloud SQL proxy 在同一路径上模拟 unix 套接字。
回答我自己的问题感觉很奇怪,但问题是:由于某种原因无法与 postgres
用户连接。最后我为函数创建了一个新的数据库用户和一个只包含字母数字字符的密码。