跳到主要內容
Open In ColabOpen on GitHub

Google AlloyDB for PostgreSQL

AlloyDB 是一項全受管的關聯式資料庫服務,可提供高效能、無縫整合和令人印象深刻的可擴展性。AlloyDB 與 PostgreSQL 100% 相容。透過 AlloyDB 的 Langchain 整合功能,擴展您的資料庫應用程式,以建構 AI 驅動的體驗。

本筆記本說明如何使用適用於 PostgreSQL 的 AlloyDB,透過 AlloyDBLoader 類別載入文件。

GitHub 上瞭解更多關於此套件的資訊。

Open In Colab

開始之前

若要執行此筆記本,您需要執行以下操作

🦜🔗 程式庫安裝

安裝整合程式庫 langchain-google-alloydb-pg

%pip install --upgrade --quiet  langchain-google-alloydb-pg

僅限 Colab: 取消註解以下儲存格以重新啟動核心,或使用按鈕重新啟動核心。對於 Vertex AI Workbench,您可以使用頂端的按鈕重新啟動終端機。

# # Automatically restart kernel after installs so that your environment can access the new packages
# 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 Project { display-mode: "form" }
PROJECT_ID = "gcp_project_id" # @param {type:"string"}

# Set the project id
! gcloud config set project {PROJECT_ID}

基本用法

設定 AlloyDB 資料庫變數

AlloyDB 執行個體頁面中找到您的資料庫值。

# @title Set Your Values Here { display-mode: "form" }
REGION = "us-central1" # @param {type: "string"}
CLUSTER = "my-cluster" # @param {type: "string"}
INSTANCE = "my-primary" # @param {type: "string"}
DATABASE = "my-database" # @param {type: "string"}
TABLE_NAME = "vector_store" # @param {type: "string"}

AlloyDBEngine 連線池

將 AlloyDB 設定為向量資料庫的需求和引數之一是 AlloyDBEngine 物件。AlloyDBEngine 會設定到您的 AlloyDB 資料庫的連線池,從而實現從您的應用程式成功連線,並遵循業界最佳實務。

若要使用 AlloyDBEngine.from_instance() 建立 AlloyDBEngine,您只需要提供 5 個項目

  1. project_id : Google Cloud 專案的專案 ID,AlloyDB 執行個體位於其中。
  2. region : AlloyDB 執行個體所在的區域。
  3. cluster: AlloyDB 叢集的名稱。
  4. instance : AlloyDB 執行個體的名稱。
  5. database : 要連線到 AlloyDB 執行個體上的資料庫名稱。

預設情況下,IAM 資料庫驗證將用作資料庫驗證方法。此程式庫使用屬於從環境來源的應用程式預設憑證 (ADC) 的 IAM 主體。

或者,也可以使用內建資料庫驗證,使用使用者名稱和密碼存取 AlloyDB 資料庫。只需將選用的 userpassword 引數提供給 AlloyDBEngine.from_instance()

  • user : 用於內建資料庫驗證和登入的資料庫使用者
  • password : 用於內建資料庫驗證和登入的資料庫密碼。

注意:本教學課程示範非同步介面。所有非同步方法都有對應的同步方法。

from langchain_google_alloydb_pg import AlloyDBEngine

engine = await AlloyDBEngine.afrom_instance(
project_id=PROJECT_ID,
region=REGION,
cluster=CLUSTER,
instance=INSTANCE,
database=DATABASE,
)

建立 AlloyDBLoader

from langchain_google_alloydb_pg import AlloyDBLoader

# Creating a basic AlloyDBLoader object
loader = await AlloyDBLoader.create(engine, table_name=TABLE_NAME)

透過預設表格載入文件

載入器會從表格傳回文件清單,使用第一欄作為 page_content,所有其他欄作為 metadata。預設表格的第一欄將作為 page_content,第二欄將作為 metadata (JSON)。每一列都會變成一個文件。

docs = await loader.aload()
print(docs)

透過自訂表格/metadata 或自訂頁面內容欄位載入文件

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

設定頁面內容格式

載入器會傳回文件清單,每列一個文件,頁面內容採用指定的字串格式,即 text (空格分隔的串聯)、JSON、YAML、CSV 等。JSON 和 YAML 格式包含標頭,而 text 和 CSV 不包含欄位標頭。

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

此頁面是否對您有幫助?