我有以下使用 Spanner 库的 Go 代码:
package main
import (
"log/slog"
"log"
"fmt"
"context"
"cloud.google.com/go/spanner"
)
func createClient(ctx context.Context, db string) (*spanner.Client, error) {
sessionPoolConfig := spanner.SessionPoolConfig{
TrackSessionHandles: true,
InactiveTransactionRemovalOptions: spanner.InactiveTransactionRemovalOptions{
ActionOnInactiveTransaction: spanner.WarnAndClose,
},
}
dataClient, err := spanner.NewClientWithConfig(
ctx, db, spanner.ClientConfig{SessionPoolConfig: sessionPoolConfig},
)
if err != nil {
slog.Error("failed to create the spanner client", "err", err)
return nil, err
}
defer dataClient.Close()
_ = dataClient
return dataClient, nil
}
var dbLink = "projects/PROJECT_NAME/instances/INSTANCE_NAME/databases/DATABASE_NAME"
func main() {
ctx := context.Background()
snapperClient, err := createClient(ctx, dbLink)
if err != nil {
log.Fatalf("failed to create a spanner client, error=%s", err.Error())
}
row, err := spannerClient.Single().ReadRow(ctx, "DATA_TABLE", spanner.Key{THE_KEY}, []string{"THE_COLUMN"})
if err != nil {
slog.Error("failed to get the DATA from spanner", "error", err.Error())
return nil, err
}
...
}
这会导致以下错误日志:
2023/11/30 22:40:03 ERROR failed to get the DATA from spanner id=4 error="spanner: code = \"InvalidArgument\", desc = \"invalid session pool\""
我不相信该服务器甚至到达了 Google Cloud Spanner 指定的数据库,但我没有收到 Spanner 客户端创建错误。我该如何修复这个
invalid session pool
错误?
在返回之前,您将在
createClient
内关闭客户端。删除 defer dataClient.Close()
,它应该按您的预期工作。
func createClient(ctx context.Context, db string) (*spanner.Client, error) {
sessionPoolConfig := spanner.SessionPoolConfig{
TrackSessionHandles: true,
InactiveTransactionRemovalOptions: spanner.InactiveTransactionRemovalOptions{
ActionOnInactiveTransaction: spanner.WarnAndClose,
},
}
dataClient, err := spanner.NewClientWithConfig(
ctx, db, spanner.ClientConfig{SessionPoolConfig: sessionPoolConfig},
)
if err != nil {
slog.Error("failed to create the spanner client", "err", err)
return nil, err
}
// Remove this
defer dataClient.Close()
// Also this isn't doing anything
_ = dataClient
return dataClient, nil
}