go - 如何将 Go API 连接到 Cassandra DB

Question

我正在使用 Go API，我需要将它连接到 Google Cloud 服务器上的 Cassandra DB。

这是我的 Go 连接代码：

func SetupDBConnection() {
    cluster := gocql.NewCluster("XX.XXX.XXX.XXX")
    cluster.Keyspace = "afterstr"
    cluster.Consistency = gocql.Quorum

    s, err := cluster.CreateSession()
    if err != nil {
        fmt.Println(err)
    }
}

但是，当我运行此代码时，出现此错误：

gocql: 无法创建会话: 控制: 无法连接到初始主机: dial tcp xx.xxx.xxx.xxx:9042: i/o timeout

这是我的谷歌云配置：

我还修改了服务器中的 cassandra.yaml 文件以更改侦听地址和 RPC 地址，以将我的 IP 与我用来运行我打开的 Go 程序的端口放在一起。（它打开了3次，因为我只是在测试一些东西）

Answer 1

尝试：

cluster.Authenticator = gocql.PasswordAuthenticator{Username: username, Password: password}