Skip to main content

Google Cloud SQL for PostgreSQL

Cloud SQL for PostgreSQL 是一个完全托管的数据库服务，可帮助您在 Google 云平台上设置、维护、管理和管理您的 PostgreSQL 关系数据库。通过 Cloud SQL for PostgreSQL 的 Langchain 集成，扩展您的数据库应用程序以构建基于人工智能的体验。

本笔记将介绍如何使用 Cloud SQL for PostgreSQL 加载文档，使用 PostgresLoader 类。

在 GitHub 上了解有关该软件包的更多信息。

在 Colab 中打开

开始之前​

要运行此笔记，您需要执行以下操作：

🦜🔗 安装库​

安装集成库 langchain_google_cloud_sql_pg。

%pip install --upgrade --quiet  langchain_google_cloud_sql_pg

仅限 Colab：取消下面的注释以重新启动内核，或使用顶部的按钮重新启动内核。对于 Vertex AI Workbench，您可以使用顶部的按钮重新启动终端。

# # 自动安装后重新启动内核，以便您的环境可以访问新的软件包
# import IPython
# app = IPython.Application.instance()
# app.kernel.do_shutdown(True)

🔐 身份验证​

作为在此笔记本中登录的 IAM 用户，进行 Google Cloud 身份验证，以便访问您的 Google Cloud 项目。

  • 如果您使用 Colab 运行此笔记，请使用下面的单元格并继续。

  • 如果您使用 Vertex AI Workbench，请查看此处的设置说明。

from google.colab import auth
auth.authenticate_user()

☁ 设置您的 Google Cloud 项目​

设置您的 Google Cloud 项目，以便您可以在此笔记本中利用 Google Cloud 资源。

如果您不知道项目 ID，请尝试以下操作：

  • 运行 gcloud config list。

  • 运行 gcloud projects list。

  • 参阅支持页面：查找项目 ID。

# @title 项目 { display-mode: "form" }
PROJECT_ID = "gcp_project_id"  # @param {type:"string"}
# 设置项目 ID
! gcloud config set project {PROJECT_ID}

基本用法​

设置 Cloud SQL 数据库值​

在Cloud SQL 实例页面中找到您的数据库变量。

# @title 在此处设置您的值 { display-mode: "form" }
REGION = "us-central1"  # @param {type: "string"}
INSTANCE = "my-primary"  # @param {type: "string"}
DATABASE = "my-database"  # @param {type: "string"}
TABLE_NAME = "vector_store"  # @param {type: "string"}

Cloud SQL 引擎​

将 PostgreSQL 设置为文档加载程序的要求和参数之一是 PostgresEngine 对象。PostgresEngine 配置了连接池到您的 Cloud SQL for PostgreSQL 数据库，使您的应用程序能够成功连接，并遵循行业最佳实践。

要使用 PostgresEngine.from_instance() 创建 PostgresEngine，您只需要提供 4 个参数：

  1. project_id：Cloud SQL 实例所在的 Google Cloud 项目的项目 ID。

  2. region：Cloud SQL 实例所在的区域。

  3. instance：Cloud SQL 实例的名称。

  4. database：要连接到的 Cloud SQL 实例上的数据库的名称。

默认情况下，将使用 IAM 数据库身份验证 作为数据库身份验证的方法。此库使用环境中来源于 应用程序默认凭据 (ADC) 的 IAM 主体。

还可以选择使用内置数据库身份验证，使用用户名和密码访问 Cloud SQL 数据库。只需向 PostgresEngine.from_instance() 提供可选的 user 和 password 参数：

  • user：用于内置数据库身份验证和登录的数据库用户。
  • password：用于内置数据库身份验证和登录的数据库密码。

注意：本教程演示了异步接口。所有异步方法都有相应的同步方法。

from langchain_google_cloud_sql_pg import PostgresEngine
engine = await PostgresEngine.afrom_instance(
    project_id=PROJECT_ID,
    region=REGION,
    instance=INSTANCE,
    database=DATABASE,
)

创建 PostgresLoader​

from langchain_google_cloud_sql_pg import PostgresLoader
# 创建一个基本的 PostgreSQL 对象
loader = await PostgresLoader.create(engine, table_name=TABLE_NAME)

通过默认表加载文档​

加载器使用第一列作为页面内容（page_content），将所有其他列作为元数据，从表中返回文档列表。默认表的第一列是页面内容（page_content），第二列是元数据（JSON）。每一行都成为一个文档。请注意，如果您希望文档具有 ID，则需要添加它们。

from langchain_google_cloud_sql_pg import PostgresLoader
# 创建一个基本的 PostgresLoader 对象
loader = await PostgresLoader.create(engine, table_name=TABLE_NAME)
docs = await loader.aload()
print(docs)

通过自定义表/元数据或自定义页面内容列加载文档​

loader = await PostgresLoader.create(
    engine,
    table_name=TABLE_NAME,
    content_columns=["product_name"],  # 可选
    metadata_columns=["id"],  # 可选
)
docs = await loader.aload()
print(docs)

设置页面内容格式​

加载器返回一个文档列表，每个文档占据一行，页面内容以指定的字符串格式呈现，例如文本（以空格分隔的连接）、JSON、YAML、CSV 等。JSON 和 YAML 格式包括标题，而文本和 CSV 不包括字段标题。

loader = await PostgresLoader.create(
    engine,
    table_name="products",
    content_columns=["product_name", "description"],
    format="YAML",
)
docs = await loader.aload()
print(docs)

Was this page helpful?


You can leave detailed feedback on GitHub.