自定義監(jiān)控指標(biāo)及上報(bào)渠道
Flink提供了監(jiān)控指標(biāo)（Metrics）來(lái)幫助您分析作業(yè)。如果已有指標(biāo)不滿足業(yè)務(wù)需要，您可以自定義監(jiān)控指標(biāo)，并支持將監(jiān)控指標(biāo)上報(bào)到其他渠道。本文為您介紹自定義配置監(jiān)控指標(biāo)，以及如何將監(jiān)控指標(biāo)上報(bào)到自建Prometheus、日志服務(wù)SLS、Kafka或自建平臺(tái)，以及多渠道上報(bào)。
注意事項(xiàng)
您可以將指標(biāo)僅上報(bào)至自建Prometheus、日志服務(wù)SLS或Kafka，也可以進(jìn)行多渠道采集上報(bào)。
上報(bào)到多渠道時(shí)
會(huì)增加額外的多渠道采集成本，同時(shí)，需要對(duì)metrics.reporters配置項(xiàng)進(jìn)行修改，詳情請(qǐng)參見(jiàn)上報(bào)到多渠道。
僅上報(bào)到Flink控制臺(tái)外的其他渠道時(shí)
實(shí)時(shí)計(jì)算Flink版不再為您開(kāi)通ARMS或云監(jiān)控服務(wù)，F(xiàn)link開(kāi)發(fā)控制臺(tái)不顯示監(jiān)控指標(biāo)，您可以在對(duì)應(yīng)的指標(biāo)上報(bào)的平臺(tái)進(jìn)行查看。
在Flink開(kāi)發(fā)控制臺(tái)已有的告警配置會(huì)失效（詳情請(qǐng)參見(jiàn)配置監(jiān)控告警），后續(xù)也無(wú)法進(jìn)行有效的告警配置，您需要在對(duì)應(yīng)的上報(bào)平臺(tái)進(jìn)行配置。
自定義監(jiān)控指標(biāo)采集
僅ARMS支持自定義指標(biāo)采集。
您可以直接在控制臺(tái)頁(yè)面目標(biāo)作業(yè)的監(jiān)控告警頁(yè)簽進(jìn)行指標(biāo)查看。如果當(dāng)前指標(biāo)不滿足您的業(yè)務(wù)需要，您可以配置自定義監(jiān)控指標(biāo)，詳情請(qǐng)參見(jiàn)自定義監(jiān)控指標(biāo)采集。
自定義監(jiān)控指標(biāo)上報(bào)渠道
上報(bào)到自建Prometheus
您需要在網(wǎng)絡(luò)連通的情況下，先在Flink開(kāi)發(fā)控制臺(tái)目標(biāo)作業(yè)部署詳情頁(yè)簽的運(yùn)行參數(shù)配置下的其他配置中配置如下代碼，并修改自建Prometheus相關(guān)參數(shù)值。配置方法詳情請(qǐng)參見(jiàn)控制臺(tái)操作
metrics.reporters: promgatewayappmgr
metrics.reporter.promgatewayappmgr.groupingKey: 'deploymentName={{deploymentName}};deploymentId={{deploymentId}};jobId={{jobId}}'
metrics.reporter.promgatewayappmgr.jobName: '{{deploymentName}}'
metrics.reporter.promgatewayappmgr.factory.class: org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterFactory
metrics.reporter.promgatewayappmgr.host: 您的pushgateway host
metrics.reporter.promgatewayappmgr.port: 您的pushgateway port以上代碼中，pushgateway host和pushgateway port需要替換為您實(shí)際的值。deploymentName、deploymentId和jobId系統(tǒng)會(huì)自動(dòng)進(jìn)行替換。
Flink和自建的Prometheus之間的網(wǎng)絡(luò)連通要求如下：
如果自建的Prometheus和Flink工作空間是相同的VPC，則需要確認(rèn)Prometheus安全組等配置允許Flink網(wǎng)段訪問(wèn)。
如果自建的Prometheus和Flink工作空間是不同的VPC，但自建的Prometheus有公網(wǎng)地址，則需要Flink配置公網(wǎng)訪問(wèn)，詳情請(qǐng)參見(jiàn)控制臺(tái)操作
如果自建的Prometheus和Flink工作空間是不同的VPC，但自建的Prometheus只有VPC的地址，則需要打通兩個(gè)VPC，詳情請(qǐng)參見(jiàn)控制臺(tái)操作
上報(bào)到日志服務(wù)SLS
您需要在網(wǎng)絡(luò)連通的情況下，先在Flink開(kāi)發(fā)控制臺(tái)目標(biāo)作業(yè)部署詳情頁(yè)簽的運(yùn)行參數(shù)配置下的其他配置中配置如下代碼，并修改SLS相關(guān)參數(shù)。配置方法詳情請(qǐng)參見(jiàn)控制臺(tái)操作
metrics.reporters: sls
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: 您的project
metrics.reporter.sls.logStore: 您的logStore
metrics.reporter.sls.endPoint: 您的endPoint
metrics.reporter.sls.accessId: 您的accessId
metrics.reporter.sls.accessKey: 您的accessKey
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}以上代碼中，您需要修改SLS相關(guān)參數(shù)，不需要修改deploymentId、deploymentName和namespace，系統(tǒng)會(huì)自動(dòng)進(jìn)行替換。Access信息詳情請(qǐng)參見(jiàn)如何查看AccessKey ID和AccessKey Secret信息？
上報(bào)到Kafka
您需要在網(wǎng)絡(luò)連通的情況下，先在Flink開(kāi)發(fā)控制臺(tái)目標(biāo)作業(yè)部署詳情頁(yè)簽的運(yùn)行參數(shù)配置下的其他配置中配置如下代碼，并修改Kafka相關(guān)參數(shù)。配置方法詳情請(qǐng)參見(jiàn)控制臺(tái)操作
metrics.reporters: monitor
metrics.reporter.monitor.factory.class: org.apache.flink.metrics.monitor.KafkaReporterFactory
metrics.reporter.monitor.kafka.bootstrap.servers: 您的servers
metrics.reporter.monitor.topicName: 您的topicName
metrics.reporter.monitor._FLINK_CLUSTER_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._JOB_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._NAMESPACE_NAME: '{{ namespace }}'以上代碼中，您需要修改自建Kafka相關(guān)參數(shù)，不需要修改deploymentName和namespace，系統(tǒng)會(huì)自動(dòng)進(jìn)行替換。
上報(bào)到多渠道
通過(guò)ARMS API上報(bào)到自建平臺(tái)
如果您開(kāi)通工作空間時(shí)選擇了Prometheus監(jiān)控服務(wù)，您可以通過(guò)ARMS API的方式獲取Flink的Metrics后，將Metrics集成在您自己的平臺(tái)上。此時(shí)，您可以在自建平臺(tái)進(jìn)行指標(biāo)查看的同時(shí)，在實(shí)時(shí)計(jì)算Flink版上仍然可以查看指標(biāo)曲線以及使用告警配置能力。
ARMS API詳情請(qǐng)參見(jiàn)API概覽。Operator相關(guān)的Metric詳情，請(qǐng)參見(jiàn)Operator Metrics。
上報(bào)到Flink控制臺(tái)和其他渠道
如果您需要上報(bào)到其他渠道進(jìn)行指標(biāo)查看的同時(shí)，在實(shí)時(shí)計(jì)算Flink版上也需要查看指標(biāo)曲線以及使用告警配置能力，您可以進(jìn)行多渠道上報(bào)配置，但會(huì)增加額外的多渠道采集成本。
例如，同時(shí)將指標(biāo)展示在Flink開(kāi)發(fā)控制臺(tái)和日志服務(wù)SLS上，先在Flink開(kāi)發(fā)控制臺(tái)目標(biāo)作業(yè)部署詳情頁(yè)簽的運(yùn)行參數(shù)配置下的其他配置中配置如下代碼，并修改SLS相關(guān)參數(shù)。
metrics.reporters: jmx,promappmgr,sls
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: 您的project
metrics.reporter.sls.logStore: 您的logStore
metrics.reporter.sls.endPoint: 您的endPoint
metrics.reporter.sls.accessId: 您的accessId
metrics.reporter.sls.accessKey: 您的accessKey
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}metrics.reporters配置項(xiàng)中包含jmx,promappmgr時(shí)，您可以在Flink開(kāi)發(fā)控制臺(tái)上查看指標(biāo)。其他配置參數(shù)詳情請(qǐng)參見(jiàn)上報(bào)到日志服務(wù)SLS。
上報(bào)到Flink控制臺(tái)外的多個(gè)渠道
上報(bào)到Flink控制臺(tái)外的其他多個(gè)渠道后，F(xiàn)link開(kāi)發(fā)控制臺(tái)不顯示監(jiān)控指標(biāo)，您需要在對(duì)應(yīng)平臺(tái)進(jìn)行監(jiān)控指標(biāo)查看，詳情請(qǐng)參見(jiàn)注意事項(xiàng)。
例如，同時(shí)將指標(biāo)上報(bào)至日志服務(wù)SLS和Kafka上，您可以在Flink開(kāi)發(fā)控制臺(tái)目標(biāo)作業(yè)部署詳情頁(yè)簽的運(yùn)行參數(shù)中配置如下代碼：
metrics.reporters: sls,monitor
metrics.reporter.sls.factory.class: org.apache.flink.metrics.sls.SLSReporterFactory
metrics.reporter.sls.project: 您的project
metrics.reporter.sls.logStore: 您的logStore
metrics.reporter.sls.endPoint: 您的endPoint
metrics.reporter.sls.accessId: 您的accessId
metrics.reporter.sls.accessKey: 您的accessKey
metrics.reporter.sls.extraTags: deploymentId={{ deploymentId }};deploymentName={{ deploymentName}};namespace={{ namespace }}
metrics.reporter.monitor.factory.class: org.apache.flink.metrics.monitor.KafkaReporterFactory
metrics.reporter.monitor.kafka.bootstrap.servers: 您的servers
metrics.reporter.monitor.topicName: 您的topicName
metrics.reporter.monitor._FLINK_CLUSTER_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._JOB_NAME: '{{ deploymentName }}'
metrics.reporter.monitor._NAMESPACE_NAME: '{{ namespace }}'配置參數(shù)詳情請(qǐng)參見(jiàn)上報(bào)到日志服務(wù)SLS和上報(bào)到Kafka。