العمليات طويلة الأمد (LRO)

تؤدي عدة طلبات إلى Google Ads API إلى عرض عمليات طويلة (LRO). تتتبّع هذه العمليات حالة مهمة يتم تنفيذها على مدار فترة زمنية طويلة بدون الحاجة إلى إجراء مكالمة RPC واحدة تحظر التنفيذ.

فئة OperationFuture

يمكنك التفاعل مع العمليات الطويلة في مكتبة برامج Java باستخدام الفئة OperationFuture. بما أنّ OperationFuture يعتمد على عميل الخدمة الأساسي لاستطلاع واجهة برمجة التطبيقات بحثًا عن تحديثات الحالة، تأكَّد من أنّ عميل الخدمة يظل مفتوحًا ونشطًا حتى تكتمل العملية.

بنية غير مقترَحة:

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);
  }
}

الإجراءات المقترَحة:

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 فقط بينما يظل OfflineUserDataJobServiceClient مفتوحًا ضمن كتلة try-with-resources.