本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 Go 連接器連線至 Aurora DSQL 叢集

Aurora DSQL Connector for Go 使用自動 IAM 身分驗證包裝 pgx。連接器會處理字符產生、SSL 組態和連線管理，讓您可以專注於應用程式邏輯。

關於連接器

Aurora DSQL 需要使用現有 Go PostgreSQL 驅動程式原生不支援的時間限制權杖進行 IAM 型身分驗證。Aurora DSQL Connector for Go 在處理 IAM 字符產生的 pgx 驅動程式上新增了身分驗證層，可讓您連線到 Aurora DSQL，而無需變更現有的 pgx 工作流程。

什麼是 Aurora DSQL 身分驗證？

在 Aurora DSQL 中，身分驗證涉及：

Aurora DSQL Connector for Go 旨在了解這些要求，並在建立連線時自動產生 IAM 身分驗證字符。

Aurora DSQL Connector for Go 的優點

Aurora DSQL Connector for Go 可讓您繼續使用現有的 pgx 工作流程，同時透過下列方式啟用 IAM 身分驗證：

主要功能

先決條件

連接器使用AWS 適用於 Go v2 的 SDK 預設登入資料鏈，依下列順序解析登入資料：

安裝

使用 Go 模組安裝連接器：

go get github.com/awslabs/aurora-dsql-connectors/go/pgx/dsql

快速入門

下列範例示範如何建立連線集區並執行查詢：

package main

import (
    "context"
    "log"
    
    "github.com/awslabs/aurora-dsql-connectors/go/pgx/dsql"
)

func main() {
    ctx := context.Background()
    
    // Create a connection pool
    pool, err := dsql.NewPool(ctx, dsql.Config{
        Host: "your-cluster.dsql.us-east-1.on.aws",
    })
    if err != nil {
        log.Fatal(err)
    }
    defer pool.Close()
    
    // Execute a query
    var greeting string
    err = pool.QueryRow(ctx, "SELECT 'Hello, DSQL!'").Scan(&greeting)
    if err != nil {
        log.Fatal(err)
    }
    log.Println(greeting)
}

組態選項

連接器支援下列組態選項：

連線字串格式

連接器支援 PostgreSQL 和 DSQL 連線字串格式：

postgres://[user@]host[:port]/[database][?param=value&...]
dsql://[user@]host[:port]/[database][?param=value&...]

支援的查詢參數：

範例：

// Full endpoint (region auto-detected)
pool, _ := dsql.NewPool(ctx, "postgres://admin@cluster.dsql.us-east-1.on.aws/postgres")

// Using dsql:// scheme (also supported)
pool, _ := dsql.NewPool(ctx, "dsql://admin@cluster.dsql.us-east-1.on.aws/postgres")

// With explicit region
pool, _ := dsql.NewPool(ctx, "postgres://admin@cluster.dsql.us-east-1.on.aws/mydb?region=us-east-1")

// With AWS profile
pool, _ := dsql.NewPool(ctx, "postgres://admin@cluster.dsql.us-east-1.on.aws/postgres?profile=dev")

進階用量

主機組態

連接器支援兩種主機格式：

完整端點 （自動偵測區域）：

pool, _ := dsql.NewPool(ctx, dsql.Config{
    Host: "your-cluster.dsql.us-east-1.on.aws",
})

叢集 ID （需要區域）：

pool, _ := dsql.NewPool(ctx, dsql.Config{
    Host:   "your-cluster-id",
    Region: "us-east-1",
})

集區組態調校

為您的工作負載設定連線集區：

pool, err := dsql.NewPool(ctx, dsql.Config{
    Host:              "your-cluster.dsql.us-east-1.on.aws",
    MaxConns:          20,
    MinConns:          5,
    MaxConnLifetime:   time.Hour,
    MaxConnIdleTime:   30 * time.Minute,
    HealthCheckPeriod: time.Minute,
})

單一連線用量

對於簡單的指令碼或不需要連線集區時：

conn, err := dsql.Connect(ctx, dsql.Config{
    Host: "your-cluster.dsql.us-east-1.on.aws",
})
if err != nil {
    log.Fatal(err)
}
defer conn.Close(ctx)

// Use the connection
rows, err := conn.Query(ctx, "SELECT * FROM users")

使用 AWS 設定檔

指定登入資料的 AWS 設定檔：

pool, err := dsql.NewPool(ctx, dsql.Config{
    Host:    "your-cluster.dsql.us-east-1.on.aws",
    Profile: "production",
})

OCC 重試

Aurora DSQL 使用樂觀並行控制 (OCC)。當兩個交易修改相同的資料時，第一個遞交獲勝，第二個收到 OCC 錯誤。

occretry 套件為具有指數退避和抖動的自動重試提供了協助程式。使用 進行安裝：

go get github.com/awslabs/aurora-dsql-connectors/go/pgx/occretry

WithRetry 用於交易寫入：

err := occretry.WithRetry(ctx, pool, occretry.DefaultConfig(), func(tx pgx.Tx) error {
    _, err := tx.Exec(ctx, "UPDATE accounts SET balance = balance - $1 WHERE id = $2", 100, fromID)
    if err != nil {
        return err
    }
    _, err = tx.Exec(ctx, "UPDATE accounts SET balance = balance + $1 WHERE id = $2", 100, toID)
    return err
})

對於 DDL 或單一陳述式，請使用 ExecWithRetry：

err := occretry.ExecWithRetry(ctx, pool, occretry.DefaultConfig(),
    "CREATE TABLE IF NOT EXISTS users (id UUID PRIMARY KEY, name TEXT)")

範例

如需更完整的範例和使用案例，請參閱 Aurora DSQL Connector for Go 範例。