如何连接到 Google Cloud 上的 Cassandra？

Question

我目前正在开发一个带有 Go api 的项目。它与 Google Cloud 服务器上的 Cassandra 进行通信。

问题是当我尝试向 Cassandra 发出请求时，Go 返回了几个错误。经过多次测试，我认为问题出在 Go 和 Cassandra 之间的连接不起作用。

是否有安全检查来建立连接？还是我只是在代码中犯了一个错误？

我使用gocql 连接到 Cassandra。这是 Go 连接脚本和调用 Cassandra 的请求。

    type DBConnection struct {
        cluster *gocql.ClusterConfig
        session *gocql.Session
    }
    
    var connection DBConnection
    
    func SetupDBConnection() {
        connection.cluster = gocql.NewCluster(google cloud server adress)
        connection.cluster.Consistency = gocql.Quorum
        connection.cluster.Keyspace = "keyspace name"
        connection.session, _ = connection.cluster.CreateSession()
    }
    
    func ExecuteQuery(query string, values ...interface{}) {
        connection.session.Query(query).Bind(values...).Exec()
    }

go cql 重新运行此错误：

gocql : 不可能的 de créer la session : 控制 : 不可能的 de se 连接器 aux hôtes initiaux : composez tcp xx.xxx.xxx.xxx:9042 : délai d'attente d'e/s

这是我的谷歌云配置屏幕

这里是我的盒子打开端口的屏幕

Answer 1

不知道你遇到了什么错误很难回答。

如果您的 Go 应用在与 Cassandra 节点不在同一子网的计算机上运行，​​您需要将 Cassandra 配置为使用计算实例的公共 IP，以便您的应用可以访问它们。这些是cassandra.yaml 中的相关属性：

listen_address: private_ip
rpc_address: public_ip

客户端/应用程序实例使用端口rpc_port（默认为9042）上的rpc_address 连接到Cassandra 节点，因此它需要是可公开访问的IP 地址。

您还需要确保 GCP 访问规则允许从运行您的应用的机器到计算实例的流量。