用于列出数据流作业的 Java API

Question

我正在尝试编写 java 代码来列出数据流作业。 我参考了https://cloud.google.com/dataflow/docs/reference/rest/v1b3/projects.jobs/list 但不推荐使用“GoogleCredential”类。我尝试将 GoogleCredential 替换为 GoogleCredentials 但在下面这一行

Dataflow dataflowService = new Dataflow.Builder(httpTransport, jsonFactory, credential)
      .setApplicationName("Google Cloud Platform Sample")
      .build();

它需要 HttpRequestInitializer 而不是凭据。

谁能帮助我如何使用凭据本身并解决此问题？

Answer 1

HttpRequestInitializer 需要在失败时执行自动重试。可以使用com.google.api.client.auth.oauth2.Credential 构造一个简单的HttpRequestInitializer，如下所示：

private HttpRequestInitializer buildInitializer(Credential credential) {
    return httpRequest -> {
      // handles abnormal HTTP responses (non 2XX responses)
      final HttpUnsuccessfulResponseHandler unsuccessfulResponseHandler =
          new HttpBackOffUnsuccessfulResponseHandler(new ExponentialBackOff())
              .setSleeper(Sleeper.DEFAULT);
      /*
      this is designed to work with only one HttpRequest at a time.
      Hence, a new instance of HttpBackOffIOExceptionHandler with new instance of
      BackOff is created for each instance of HttpRequest
      */
      HttpBackOffIOExceptionHandler httpBackOffIOExceptionHandler =
          new HttpBackOffIOExceptionHandler(new ExponentialBackOff()).setSleeper(Sleeper.DEFAULT);
      httpRequest.setInterceptor(credential).setUnsuccessfulResponseHandler(unsuccessfulResponseHandler)
          .setIOExceptionHandler(httpBackOffIOExceptionHandler)
          .setConnectTimeout((int) TimeUnit.MINUTES.toMillis(3))
          .setReadTimeout((int) TimeUnit.MINUTES.toMillis(3))
          .setThrowExceptionOnExecuteError(false).setSuppressUserAgentSuffix(true);

    };
  }