postgresql - 无法使用 node-postgres 连接到 Cloud SQL
问题描述
我一直在尝试使用该pg
模块连接到我的 Cloud SQL 实例,但到目前为止还没有成功。
我在网上看了很多,但对这个话题不太了解。我还想在某个时候在 Cloud Run 上部署我的 Express 应用程序并让它连接到我的 Cloud SQL 实例,但我不知道该怎么做。
这是我不明白的事情的清单,并希望简要解释一下:
- 什么是 Unix 套接字连接,为什么我应该在普通连接上使用它们?
- 什么是 Cloud SQL 代理?我需要使用它吗?如果是这样,为什么?
- 我需要做任何额外的工作才能从 Cloud Run 连接到我的 Cloud SQL 实例吗?
以下是我尝试使用该pg.Client
对象的所有连接对象和连接字符串:
- 第一个连接字符串:
postgresql+psycopg2://postgres:password@/cloudsql/myapp:us-central1:mydb?host=/var/lib/postgresql
- 第二个连接字符串:
postgresql://postgres:password@hostip:5432/myapp:us-central1:mydb
- 第三个连接字符串:
postgresql://postgres:password@hostip:5432/sarcdb
- 连接对象:
{ host: "/cloudsql/myapp:us-central1:mydb", username: "postgres", password: "password", database: "mydb" }
所有这些都给我一个Connection terminated unexpectedly
错误。
解决方案
Node.js 和 Cloud SQL的Cloud Functions 文档(向下滚动到 PostgreSQL)包含有关构建连接字符串和凭据所需的其他配置的适用信息。
为您的应用准备好之后,您需要将 Cloud SQL 实例添加到您的 Cloud Run 服务,然后它才能使用该连接字符串访问数据库。
这里直接从文档中复制代码示例,使用 Cloud Run max
1 的配置可能跟不上其他并发设置。
const pg = require('pg');
/**
* TODO(developer): specify SQL connection details
*/
const connectionName =
process.env.INSTANCE_CONNECTION_NAME || '<YOUR INSTANCE CONNECTION NAME>';
const dbUser = process.env.SQL_USER || '<YOUR DB USER>';
const dbPassword = process.env.SQL_PASSWORD || '<YOUR DB PASSWORD>';
const dbName = process.env.SQL_NAME || '<YOUR DB NAME>';
const pgConfig = {
max: 1,
user: dbUser,
password: dbPassword,
database: dbName,
};
if (process.env.NODE_ENV === 'production') {
pgConfig.host = `/cloudsql/${connectionName}`;
}
// Connection pools reuse connections between invocations,
// and handle dropped or expired connections automatically.
let pgPool;
exports.postgresDemo = (req, res) => {
// Initialize the pool lazily, in case SQL access isn't needed for this
// GCF instance. Doing so minimizes the number of active SQL connections,
// which helps keep your GCF instances under SQL connection limits.
if (!pgPool) {
pgPool = new pg.Pool(pgConfig);
}
pgPool.query('SELECT NOW() as now', (err, results) => {
if (err) {
console.error(err);
res.status(500).send(err);
} else {
res.send(JSON.stringify(results));
}
});
// Close any SQL resources that were declared inside this function.
// Keep any declared in global scope (e.g. mysqlPool) for later reuse.
};
推荐阅读
- vue.js - Vuex-module-decorator,修改动作内部的状态
- r - R找到一组点“下方”最近的凸曲线
- jquery - 如何使用jquery在表格中显示html表单中的数据
- cron - crontab 不执行简单的 shell 脚本来关闭交换并重新打开交换
- javascript - JS 弹出窗口在 Safari 上不起作用(隐藏/显示)
- c++ - 如何在 MFC 工具栏中添加自定义控件
- flutter - 如何从它自己的 onTap 中禁用 ListTile?
- python - 如何提取可以在字符串中多次出现的片段
- javascript - 单个列搜索(文本输入)在我的 Rails 代码中不起作用
- rdf - 使用 Jena Fuseki 导入 ~500MB Turtle 会产生错误和崩溃