问题标签 [cadence-workflow]

我已经将BackgroundActivityContext视为向活动提供全局资源的一种方式，但是有没有办法通过上下文而不是作为活动的显式参数提供范围为单个工作流运行的值到该工作流中的所有活动？我正在考虑的用例是提供与工作流执行相关的用户 ID 之类的内容，然后即使活动不将用户 ID 作为参数，也可以将其作为字段添加到活动的日志中.

I am looking for retry option example for cadence in java, for example I am trying below code snippet but it seems the activity is not re-tried

for the above activity I am expecting that if it fails should be re-tried automatically, below is how I am calling it

Please let me know if I am doing anything incorrect here,

Below is the snapshot from the frontend

对于失败的工作流，前端是否有节奏或时间的重试选项？

在我做 docker-compose up 之后我遇到了错误

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

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

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

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

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

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

cosmosCassandraContactPoint : xyz.cassandra.cosmos.azure.com cosmosCassandraPort : 10350 cosmosCassandraUser : xyz cosmosCassandraPassword : xyz

我正在使用 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)

从我的角度来看，我可以将外部 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

在外部使用cassandra运行cadence时，如何提供cassandra的具体端口、用户名、密码。

使用默认端口：9042 和 cassandra 的身份验证禁用，我们可以使用以下命令运行 cadence：docker run -e CASSANDRA_SEEDS=10.xxx e ubercadence/server

如何指定不同的端口、用户名、密码？

我正在评估使用 Cadence 执行长时间运行的批量操作。我有以下（Kotlin）代码：

这适用于较少数量的实体，但我很快遇到以下异常：

看来我很快就耗尽了线程池，而 Cadence 无法安排新任务。

我通过将定义更改updateNames为：

这基本上处理了 200 个块中的项目，并等待每个块完成，然后再移动到下一个块。我担心这将如何执行（块中的单个错误将在重试时停止处理以下块中的所有记录）。我还关心 Cadence 在发生崩溃时能够恢复此功能的进度的能力。

我的问题是：是否有一种惯用的 Cadence 方式来做到这一点，不会导致这种立即的资源耗尽？我使用了错误的技术还是这只是一种幼稚的方法？

cadence默认使用的时区是什么？

我们如何根据时区更改 cron 表达式？例如，如果用户从与 cadence 的服务器时区不同的时区输入 cron 计划，假设用户在 GMT + 5 每天下午 1 点输入，那么它应该在服务器中的上午 9 点运行（假设 cadence 的服务器时区仅为 GMT）。

我正在使用 golang cadence 客户端编写工作流程。任何帮助表示赞赏。

我正在尝试使用 WorkflowServiceTChannel 查询 ListOpenWorkflowExecutions。我总是得到 0 的 ListOpenWorkflowExecutionsResponse 大小。我无法弄清楚我哪里出错了。以下是我正在使用的 java 代码。