[ https://issues.apache.org/jira/browse/FLINK-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16532735#comment-16532735 ]
ASF GitHub Bot commented on FLINK-9187: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6184#discussion_r200122215 --- Diff: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java --- @@ -0,0 +1,94 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.flink.metrics.prometheus; + +import org.apache.flink.annotation.PublicEvolving; +import org.apache.flink.metrics.Metric; +import org.apache.flink.metrics.MetricConfig; +import org.apache.flink.metrics.reporter.MetricReporter; +import org.apache.flink.metrics.reporter.Scheduled; +import org.apache.flink.util.AbstractID; + +import io.prometheus.client.CollectorRegistry; +import io.prometheus.client.exporter.PushGateway; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.IOException; + +/** + * /** + * {@link MetricReporter} that exports {@link Metric Metrics} via Prometheus Pushgateway. + */ +@PublicEvolving +public class PrometheusPushGatewayReporter extends AbstractPrometheusReporter implements Scheduled { + private final Logger log = LoggerFactory.getLogger(PrometheusPushGatewayReporter.class); + + public static final String ARG_HOST = "host"; + public static final String ARG_PORT = "port"; + public static final String ARG_JOB_NAME_PREFIX = "prefix"; + + public static final char JOB_NAME_SEPARATOR = '-'; + public static final String DEFAULT_JOB_NAME_PREFIX = "flink"; + + private PushGateway pushGateway; + private String jobName; + + @Override + public void open(MetricConfig config) { + + // reporter configs + String host = config.getString(ARG_HOST, null); + int port = config.getInteger(ARG_PORT, -1); + String jobNamePrefix = config.getString(ARG_JOB_NAME_PREFIX, DEFAULT_JOB_NAME_PREFIX); + + // host port + if (host == null || host.length() == 0 || port < 1) { + throw new IllegalArgumentException("Invalid host/port configuration. Host: " + host + " Port: " + port); + } + + // jobname + String random = new AbstractID().toString(); + jobName = jobNamePrefix + JOB_NAME_SEPARATOR + random; --- End diff -- I will make the random suffix optional for cases where users can supply different configurations to each container. > add prometheus pushgateway reporter > ----------------------------------- > > Key: FLINK-9187 > URL: https://issues.apache.org/jira/browse/FLINK-9187 > Project: Flink > Issue Type: New Feature > Components: Metrics > Affects Versions: 1.4.2 > Reporter: lamber-ken > Priority: Minor > Labels: features, pull-request-available > Fix For: 1.6.0 > > > make flink system can send metrics to prometheus via pushgateway. -- This message was sent by Atlassian JIRA (v7.6.3#76005)