将Cadence连接到Azure Cosmo Cassandra API

Question

我正在运行节奏，卡桑德拉使用 docker run -e CASSANDRA_SEEDS=10.x.x.x e 超级数据库/服务器运行：。并成功运行。

Azure cosmos表示，任何在Cassandra上运行的系统都可以使用提供的cosmos cassandra APi使用Azure cosmos，方法是修改客户端连接创建代码，例如：GO app示例代码：

func GetSession(cosmosCassandraContactPoint, cosmosCassandraPort, cosmosCassandraUser, cosmosCassandraPassword string) *gocql.Session {
    clusterConfig := gocql.NewCluster(cosmosCassandraContactPoint)
    port, err := strconv.Atoi(cosmosCassandraPort)
    
    clusterConfig.Authenticator = gocql.PasswordAuthenticator{Username: cosmosCassandraUser, Password: cosmosCassandraPassword}
    clusterConfig.Port = port
    clusterConfig.SslOpts = &gocql.SslOptions{Config: &tls.Config{MinVersion: tls.VersionTLS12}}
    clusterConfig.ProtoVersion = 4
    
    session, err := clusterConfig.CreateSession()
    ...
    return session
}

从我这边开始，我可以将外部cassandra的cqlsh（cadence用于持久化）连接到azure cosmos，并且可以在azure cosmo db中创建KeySpace，表。但是，当我运行Cadence服务器时，所有新表仍然是在本地cassandra本身（而不是Axure cosmos）上创建的，可能是，cassandra仅连接到cassandra。

所以基本上有两个问题分享如下:

1.由于cadence是用GO编写的，我们可以修改源代码以建立与AzureCosmoDb的连接吗。或

CosmosCassandraContactPoint：xyz.cassandra.cosmos.azure.comcosmosCassandraPort： 10350 cosmosCassandraUser： xyz cosmosCassandraPassword： xyz

Answer 1

我正在积极努力支持其他非关系型数据库：https://github.com/uber/cadence/issues/3514完成后，使用Azure cosmos/AWS Keyspace会更容易。

基本上，我们只需要从现有的Cassandra模型定制一小部分。