有状态函数中的自定义指标

【问题标题】：Custom metrics in Stateful functions有状态函数中的自定义指标
【发布时间】：2021-12-19 00:36:39
【问题描述】：

大家好，最近开始使用 Apache Flink Stateful 函数。我们正在使用 Flink 报告器将指标放入 InfluxDB https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/metric_reporters/ 有状态函数提供了“函数”范围，其中包含几个开箱即用的指标 https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.2/deployment-and-operations/metrics.html 但这还不够，还需要添加自定义指标和测量值。所有源代码似乎都无法扩展，我无法找到正确的方法来做到这一点。如果有人成功完成此任务，请分享您的经验。

【问题讨论】：

标签： apache-flink metrics stateful

【解决方案1】：

最近，嵌入式函数 SDK 的主分支中添加了添加用户定义指标的功能。见JIRA issue。

通过该更改，您可以执行以下操作：

public class MyFn implements StatefulFunction {

@Override
public void invoke(Context context, Object input) {
    if (isBadMessage(input)) {
        context.metrics().counter("bad-message").inc();
    } else {
        processNormalMessage(context, input);
    }
}

...
}

如果您正在使用远程功能，请让 Apache Flink 用户邮件列表了解它，以便维护人员考虑将该功能的范围扩展到远程功能！

如果您赶时间，并且对自己构建项目感到满意，您可以立即尝试。

【讨论】：