0

我正在使用 docker run -e CASSANDRA_SEEDS=10.xxx e ubercadence/server: 在外部运行 cassandra 运行 cadence。并且它运行成功。

Azure cosmos 说,在 Cassandra 上运行的任何系统都可以使用 Azure cosmos 使用提供的 cosmos cassandra APi,通过修改客户端连接创建代码,例如:GO 应用示例代码:

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)上创建,可能是,cadence 仅连接到 cassandra。

所以下面基本上有2个问题:

1.cadence是用GO编写的,能否修改源码建立与AzureCosmoDb的连接。或者

或者我们可以在分别运行 cassandra 和 cadence 时传递 cosmocassandra 的主机、端口、用户名、密码吗(docker run -e CASSANDRA_SEEDS=10.xxx e ubercadence/server:) cosmosCassandraContactPoint : xyz.cassandra.cosmos.azure.com cosmosCassandraPort : 10350 cosmosCassandra用户:xyz cosmosCassandra密码:xyz

4

1 回答 1

-1

我正在积极支持其他 NoSQL DB:https ://github.com/uber/cadence/issues/3514 完成后使用 Azure cosmos 会更容易。

于 2020-09-19T02:18:19.870 回答