Managed Service for Prometheus:Envio de dados com o Pushgateway

Visão geral da solução

Se sua fonte de dados não puder ou não dever ser coletada periodicamente pelo Prometheus Server, como em ambientes sem conectividade de rede estável, use o Pushgateway. A fonte de dados envia as informações de monitoramento para o Pushgateway e o Prometheus Server as recupera em intervalos regulares. Siga estas etapas:

1. Obter o endpoint do Pushgateway: obtenha o endpoint do Pushgateway no console do Managed Service for Prometheus.

2. Reportar dados: use o comando curl ou um SDK open source para enviar os dados. Garanta que o Prometheus colete e monitore as métricas de forma rápida e confiável.

3. Adicionar configuração de proteção de dados (opcional): o protocolo padrão do Pushgateway não inclui recursos de proteção de dados. O SDK do Pushgateway suporta apenas autenticação básica (Basic Auth) e não oferece métodos avançados ou padronizados. Qualquer cliente com acesso ao endpoint do Pushgateway consegue enviar dados. Para proteger suas informações, obtenha um token no console do Managed Service for Prometheus e implemente a autenticação padrão baseada em JWT.

Pré-requisitos

Você já criou uma instância do Prometheus. Para mais informações, consulte:

• Observabilidade de contêineres

• Observabilidade de hosts

• Observabilidade de serviços da Alibaba Cloud

• Observabilidade de contêineres

• Observabilidade de hosts

• Observabilidade de serviços da Alibaba Cloud

Etapa 1: Obter o endpoint do Push Gateway

1. Acesse o console do Cloud Monitor. No painel de navegação à esquerda, escolha Managed Service for Prometheus > Instances. A página Instances será exibida.

2. Na barra de menus na parte superior da página, selecione a região onde reside sua instância do Prometheus. Na coluna Actions do cluster de destino, clique em Settings.

3. Na aba Settings, localize a seção Pushgateway URL e copie a URL pública.

   Esta seção também fornece uma URL do Push Gateway para rede privada. Escolha a URL adequada conforme seu ambiente de rede.

Etapa 2: Reportar dados

completionTime := prometheus.NewGauge(prometheus.GaugeOpts{
    Name: "db_backup_last_completion_timestamp_seconds",
    Help: "The timestamp of the last successful completion of a DB backup.",
})
completionTime.SetToCurrentTime()
url :   = "https://cn-hangzhou.arms.aliyuncs.com/prometheus/52b12ea9cf4bb9e35****/16727530178****/1df8lj***/cn-hangzhou/api/v2"
pusher := push.New(url, "test").
    Collector(completionTime).Client(http.DefaultClient).
    Grouping("key1", "test1").Grouping("key2", "dfdf/sdsd/").
    Format(expfmt.FmtProtoDelim)
if err := pusher.Push(); err != nil {
    fmt.Println("Could not push completion time to PushGateway: ", err)
}

CollectorRegistry registry = new CollectorRegistry();
Gauge duration = Gauge.build()
        .name("my_batch_job_duration_seconds").help("Duration of my batch job in seconds.").register(registry);
Gauge.Timer durationTimer = duration.startTimer();
try {
    // Your code here.
    // This is only added to the registry after success,
    // so that a previous success in the Pushgateway isn't overwritten on failure.
    Gauge lastSuccess = Gauge.build()
            .name("my_batch_job_last_success").help("Last time my batch job succeeded, in unixtime.").register(registry);
    lastSuccess.setToCurrentTime();
} finally {
    durationTimer.setDuration();
    PushGateway pg = new PushGateway(new URL("https://cn-hangzhou.arms.aliyuncs.com/prometheus/52b12ea9cf4bb9e35****/16727530178****/1df8lj***/cn-hangzhou/api/v2"));
    pg.pushAdd(registry, "my_batch_job");
}

echo "some_metric 3.14" | curl -H "Content-Type: text/plain; version=0.0.4; charset=utf-8" --data-binary @- https://cn-hangzhou.arms.aliyuncs.com/prometheus/51bbea9ck41b9e35****/16727530178****/1df8lj***/cn-hangzhou/api/v2/metrics/job/job_name/label_key_1/label_value_1/label_key_2/label_value_2

completionTime := prometheus.NewGauge(prometheus.GaugeOpts{
    Name: "db_backup_last_completion_timestamp_seconds",
    Help: "The timestamp of the last successful completion of a DB backup.",
})
completionTime.SetToCurrentTime()
url :   = "https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway"
pusher := push.New(url, "test").
    Collector(completionTime).Client(http.DefaultClient).
    Grouping("key1", "test1").Grouping("key2", "dfdf/sdsd/").
    BasicAuth("ak", "sk").  
    Format(expfmt.FmtProtoDelim)
if err := pusher.Push(); err != nil {
    fmt.Println("Could not push completion time to PushGateway: ", err)
}

CollectorRegistry registry = new CollectorRegistry();
Gauge duration = Gauge.build()
        .name("my_batch_job_duration_seconds").help("Duration of my batch job in seconds.").register(registry);
Gauge.Timer durationTimer = duration.startTimer();
try {
    // Your code here.
    // This is only added to the registry after success,
    // so that a previous success in the Pushgateway isn't overwritten on failure.
    Gauge lastSuccess = Gauge.build()
            .name("my_batch_job_last_success").help("Last time my batch job succeeded, in unixtime.").register(registry);
    lastSuccess.setToCurrentTime();
} finally {
    durationTimer.setDuration();
    PushGateway pg = new PushGateway(new URL("https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway"));       
    pg.setConnectionFactory(new BasicAuthHttpConnectionFactory("ak", "sk"));  
    pg.pushAdd(registry, "my_batch_job");
}

echo "some_metric 3.14" | curl -u 'ak:sk' -H "Content-Type: text/plain; version=0.0.4; charset=utf-8" --data-binary @- https://k8s-log-c8b5d0a212ffa41cxxxx.cn-hangzhou.log.aliyuncs.com/prometheus/k8s-log-c8b5d0a212ffa41c0a5xxxx/aliyun-prom-c8b5d0a212ffa41c0xxxx/api/v1/pushgateway/metrics/job/job_name/label_key_1/label_value_1/label_key_2/label_value_2

Verificar resultados

Use o Grafana para confirmar se os dados foram enviados com sucesso.

1. Acessar o painel ApiServer: no painel de navegação à esquerda, selecione Dashboards. Em seguida, clique no hyperlink do painel ApiServer. O sistema redirecionará você para a página do painel.

2. Selecionar Explore para visualizar dados: na página do painel, passe o mouse sobre o ícone no painel de navegação à esquerda. Na caixa pop-up, clique em Explore. No lado direito da página Explore, use o menu suspenso para selecionar a instância Explore correspondente e verifique se os dados foram enviados com sucesso.

   No campo Metrics, insira o nome da métrica enviada (como db_backup_last_completion_timestamp_seconds). Defina Query type como Range. Após clicar em Run, se uma curva aparecer na área Graph abaixo, os dados foram enviados com sucesso.