Go クライアント ライブラリを使用して Spanner Omni に接続する

プレビュー

このプロダクトまたは機能はプレビュー版であり、サービス固有規約の 一般サービス規約 セクションの「pre-GA サービス規約」の対象となります。ソフトウェア プログラムの開発、 テスト、プロトタイピング、デモンストレーションのみを目的として使用できます。データ 処理や商用目的で使用することはできません。pre-GA のプロダクトと機能は「現状のまま」利用できますが、 サポートが制限されることがあります。詳細については、 リリース ステージ の説明をご覧ください。

このドキュメントでは、Go クライアント ライブラリを構成して Spanner Omni への安全な接続を確立する方法について説明します。これらの接続は、データベース管理クライアントまたはデータベース クライアントを作成するときにクライアント オプションを設定することで確立します。

Go クライアント ライブラリは、平文、TLS、mTLS 接続をサポートしています。すべての 接続タイプで、認証情報を Spanner Omni エンドポイントに 送信しないように、option.WithoutAuthentication()を含めます。 Google Cloud

詳細については、Spanner ドキュメントの Go での Spanner の使用を開始する をご覧ください。

平文による通信

平文による通信を確立するには、次のコードを実行します。

import ("google.golang.org/grpc/credentials/insecure")

adminClient, err := database.NewDatabaseAdminClient(ctx,
    option.WithEndpoint(OMNI_ENDPOINT),
option.WithoutAuthentication(),
option.WithGRPCDialOption(grpc.WithTransportCredentials(insecure.NewCredentials())),
)

clientConfig := ClientConfig{
        IsExperimentalHost: true,
    }
databaseClient, err := spanner.NewClientWithConfig(ctx, db,
clientConfig,
    option.WithEndpoint(OMNI_ENDPOINT),
option.WithoutAuthentication(),
option.WithGRPCDialOption(grpc.WithTransportCredentials(insecure.NewCredentials())),
)

TLS 接続

TLS 接続を確立するには、次のコードを実行します。

func createClients(ca_certificate, database, omniEndpoint string){
    // TLS CA cert configuration
caCert, err := os.ReadFile(ca_certificate)
    capool := x509.NewCertPool()
capool.AppendCertsFromPEM(caCert)
    creds := credentials.NewTLS(&tls.Config{RootCAs: capool})

    adminClient, err := database.NewDatabaseAdminClient(ctx,
        option.WithEndpoint(omniEndpoint),
option.WithGRPCDialOption(grpc.WithTransportCredentials(creds)),
option.WithoutAuthentication(),
)
clientConfig := ClientConfig{
        IsExperimentalHost: true,
    }
databaseClient, err := spanner.NewClientWithConfig(ctx, db,
clientConfig,
        option.WithEndpoint(omniEndpoint),
option.WithoutAuthentication(),
option.WithGRPCDialOption(grpc.WithTransportCredentials(creds)),
)
}

mTLS 接続

mTLS 接続を確立するには、次のコードを実行します。

func createClients(ca_certificate, client_certificate, client_key, database, omniEndpoint string){
    // mTLS cred configuration
    caCert, err := os.ReadFile(ca_certificate)
        capool := x509.NewCertPool()
        capool.AppendCertsFromPEM(caCert)
        cert := tls.LoadX509KeyPair(client_certificate, client_key)
        creds := credentials.NewTLS(&tls.Config{Certificates: []tls.Certificate{cert}, RootCAs: capool})

        adminClient, err := database.NewDatabaseAdminClient(ctx,
            option.WithEndpoint(omniEndpoint),
            option.WithoutAuthentication(),
    option.WithGRPCDialOption(grpc.WithTransportCredentials(creds))
    )
    clientConfig := ClientConfig{
            IsExperimentalHost: true,
        }
    databaseClient, err := spanner.NewClientWithConfig(ctx, db,
    clientConfig,
            option.WithEndpoint(omniEndpoint),
    option.WithoutAuthentication(),
    option.WithGRPCDialOption(grpc.WithTransportCredentials(creds)),
    )
}