如何以节奏测量正在运行的工作流的数量

Question

我想在普罗米修斯监控当前运行的节奏工作流的数量。

我检查了由不同的cadence服务(如< code>cadence_history 、< code>cadence_worker 、< code>cadence_frontend等)导出的指标，我能找到的唯一与工作流相关的指标是:

• activity_end_to_end_latency直方图（workflowType是标签之一）
• 工作流成功计数器

因此，似乎有一些指标可以分析已完成的工作流程，但没有关于当前工作流程的信息。我是对的还是我错过了什么？

这意味着我必须自己导出所需的指标，我看到了两种可能的解决方案：

< li >创建标尺并在我的工作流程开始和停止时增加/减少标尺，例如:

func MyWorkflow(ctx workflow.Context) error {
    mymetrics.gauge.Inc()

    if err := workflow.ExecuteActivity(ctx, someActivity).Get(ctx, nil); err != nil {
        mymetrics.gauge.Dec()
        return err
    }

    // ...

    mymetrics.gauge.Dec()
    return nil
}

这种方法的缺点是由用户手动终止的工作流将不能被正确地度量。

< li >创建一个prometheus exporter，并使用< code > cadence . client . listowelconflow 函数收集正在运行的工作流数量。然而，cadence文档说“大量使用这个API可能会导致巨大的持久性压力”，所以我认为在prometheus exporter内部调用它是一个非常糟糕的主意。

你认为还有其他可能的解决办法吗？

Answer 1

因此，似乎有一些指标可以分析已完成的工作流程，但没有关于当前工作流程的信息。我是对的还是我错过了什么？

这是正确的。没有发出类似的度量。

但是，节奏文档说“大量使用此API可能会导致巨大的持久性压力”

如果您使用ElasticSearch的高级可见性，情况就不一样了。

但是如果使用高级可见性，应该使用“CountWorkflowExecution”API来代替。这将更有效地计算打开的工作流。

如果使用基本可见性，如果数量过大，则可能是持久性的性能问题。因为您必须迭代页面才能获得数字。