Uzun süreli işlemler (LRO'lar)

Google Ads API'ye yapılan çeşitli çağrılar, uzun süreli işlemler (LRO) döndürür. Bunlar, tek bir engelleme RPC'si gerektirmeden uzun bir süre boyunca yürütülen bir işin durumunu izler.

OperationFuture sınıfı

Java istemci kitaplığında LRO'larla etkileşim kurmak için OperationFuture sınıfını kullanırsınız. OperationFuture, durum güncellemeleri için API'yi yoklamak üzere temel hizmet istemcisine bağlı olduğundan, işlem tamamlanana kadar hizmet istemcisinin açık ve etkin kaldığından emin olun.

Önerilmeyen:

private void executeOperation(String jobName) throws Exception {
  OperationFuture<Empty, OfflineUserDataJobMetadata> future =
      startLongRunningOperation(jobName);
  // FAILS: The service client was already closed when
  // startLongRunningOperation() exited its try-with-resources block, so
  // future.get() fails when polling.
  future.get();
}

private OperationFuture<Empty, OfflineUserDataJobMetadata>
    startLongRunningOperation(String jobToStart) {
  try (OfflineUserDataJobServiceClient offlineUserDataJobServiceClient =
      googleAdsClient
          .getLatestVersion()
          .createOfflineUserDataJobServiceClient()) {
    // Issues an asynchronous request to run the offline user data job.
    return offlineUserDataJobServiceClient.runOfflineUserDataJobAsync(
        jobToStart);
  }
}

Önerilen:

private void executeOperation(String jobName) throws Exception {
  try (OfflineUserDataJobServiceClient offlineUserDataJobServiceClient =
      googleAdsClient
          .getLatestVersion()
          .createOfflineUserDataJobServiceClient()) {
    OperationFuture<Empty, OfflineUserDataJobMetadata> future =
        startLongRunningOperation(offlineUserDataJobServiceClient, jobName);
    // Waits for the operation to complete (with a timeout) while the client is
    // still open.
    future.get(5, TimeUnit.MINUTES);
  }
}

private OperationFuture<Empty, OfflineUserDataJobMetadata>
    startLongRunningOperation(
        OfflineUserDataJobServiceClient offlineUserDataJobServiceClient,
        String jobToStart) {
  return offlineUserDataJobServiceClient.runOfflineUserDataJobAsync(jobToStart);
}

OperationFuture öğesinin yalnızca try-with-resources bloğunda OfflineUserDataJobServiceClient açıkken kullanıldığına dikkat edin.