将Cadence连接到Azure Cosmo Cassandra API（Cadence工作流）

Question

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

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

Func Get会话（cosmosCassandraContactPoint， cosmosCassandraPort， cosmosCassandraUser， cosmosCassandraPassword string）*gocql.Session{clusterConfig：=gocql.NewCluster（cosmosCassandraContactPoint）端口，错误：=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

} 从我的角度来看，我可以将外部卡桑德拉的cqlsh（其节奏用于持久化）连接到蔚蓝宇宙，并且可以在蔚蓝宇宙数据库中创建KeySpace表。但是，当我运行Cadence服务器时，所有新表仍然在本地卡桑德拉本身（而不是Axure宇宙）上创建，节奏仅连接到卡桑德拉。

所以下面基本上有2个问题分享：

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

或者我们可以在分别运行cassandra和cadence时传递cosmocassandra的主机、端口、用户名、密码(docker run-e CASSANDRA _ SEEDS = 10 . x . x . e Uber cadence/server:)cosmosCassandraContactPoint:xyz.cassandra.cosmos.azure.com cosmosCassandraPort:10350 cosmosCassandraUser:XYZ cosmoscassandrappassword:XYZ

Answer 1

非常令人兴奋的是，Azure Cosmo 卡桑德拉现在支持 LWT！

我快速看了一下文件

我认为它可能不会直接工作，因为它不支持LoggedBatch

但Cadence正在使用记录的批处理：

我认为在Cadence中使用未记录的批处理可能可以。因为所有操作总是在一个分区中。来自Datastax文档：

单分区批处理操作是自动原子的，而多分区批处理作业需要使用批处理日志来确保原子性

这意味着对于Cadence来说，使用未标记的批次应该是相同的。（尽管我认为Cadence选择使用日志批处理以确保安全）

如果我们在Cadence Cassandra插件中稍微更改代码，它应该可以工作