这个例子主要说明, 如何执行一个批处理任务，并且在没有执行成功时报警

    执行批量作业的代码：

    1. import io.prometheus.client.CollectorRegistry;
    2. import io.prometheus.client.Gauge;
    3. import io.prometheus.client.exporter.PushGateway;
    5.  CollectorRegistry registry = new CollectorRegistry();
    6.  Gauge duration = Gauge.build()
    7.      .name("my_batch_job_duration_seconds")
    9.      .register(registry);
    10.  Gauge.Timer durationTimer = duration.startTimer();
    11.  try {
    12.    // Your code here.
    14.    // This is only added to the registry after success,
    15.    Gauge lastSuccess = Gauge.build()
    17.        .help("Last time my batch job succeeded, in unixtime.")
    18.        .register(registry);
    19.    lastSuccess.setToCurrentTime();
    20.  } finally {
    21.    durationTimer.setDuration();
    22.    PushGateway pg = new PushGateway("127.0.0.1:9091");
    23.    pg.pushAdd(registry, "my_batch_job");
    24.  }

    如果任务最近没有运行，请创建一个警报到Alertmanager。将以下内容添加到Pushgateway的Prometheus服务的记录规则中：record rules ALERT MyBatchJobNotCompleted IF min(time() - my_batch_job_last_success_unixtime{job="my_batch_job"}) > 60 * 60 FOR 5m WITH { severity="page" } SUMMARY "MyBatchJob has not completed successfully in over an hour"