Przesłane pliki uporządkowanych danych nie tworzą ani nie aktualizują zasobów od razu. Przetwarzanie plików SDF i wprowadzanie wynikających z nich zmian może zająć Display & Video 360 od kilku sekund do kilku godzin. Możesz przesyłać wiele plików jednocześnie, o ile nie zawierają one nakładających się zasobów.
Aby sprawdzić, czy zadanie zostało ukończone, regularnie pobieraj operację za pomocą funkcji
sdfuploadtasks.operations.get i sprawdzaj, czy pole
done ma wartość True i czy zadanie zostało ukończone. Ten proces jest nazywany „odpytywaniem”.
Jeśli zadanie zostało zakończone, ustawione jest pole response lub error. Jeśli pole error jest wypełnione, zadanie zakończyło się niepowodzeniem, a szczegóły dotyczące tego niepowodzenia są dostępne w obiekcie Status. Jeśli pole response jest wypełnione, do pola zostanie przypisany znak SdfUploadTask. Oznacza to, że Display & Video 360 przetworzył przesłany plik SDF. Pobierz pliki wyników z lokalizacji podanej w polu SdfUploadTask.resourceName.
Nieefektywna implementacja odpytywania, która sprawdza długotrwały raport, zużywa dużo limitu żądań interfejsu API. Aby ograniczyć ponowne próby i oszczędzać limit, używaj wzrastającego czasu do ponowienia.
Oto jak sprawdzić stan operacji przesyłania pliku SDF za pomocą wzrastającego czasu do ponowienia:
# Import the necessary libraries import random import time # Provide the name of the sdfuploadtask operation. operation_name = operation-name # Set the following values that control retry behavior while the operation # is running. # Minimum amount of time between polling requests. Defaults to 5 seconds. min_retry_interval = 5 # Maximum amount of time between polling requests. Defaults to 5 minutes. max_retry_interval = 5 * 60 # Maximum amount of time to spend polling. Defaults to 5 hours. max_retry_elapsed_time = 5 * 60 * 60 # Configure the sdfuploadtasks.operations.get request. get_request = service.sdfuploadtasks().operations().get(operation_name) sleep = 0 start_time = time.time() while True: # Get current status of the report. operation = get_request.execute() if "done" in operation: if "error" in operation: print( f'The operation finished in error with code ' f'{operation["error"]["code"]}: {operation["error"]["message"]}') else: print( f'The operation completed successfully. The result files can be ' f'downloaded at {operation["response"]["resourceName"]}.') break elif time.time() - start_time > max_retry_elapsed_time: print("Polling deadline exceeded.") break sleep = next_sleep_interval(sleep) print( f'Operation {operation_name} is still running, sleeping for ' f'{sleep} seconds.') time.sleep(sleep) def next_sleep_interval(previous_sleep_interval): """Calculates the next sleep interval based on the previous.""" min_interval = previous_sleep_interval or min_retry_interval max_interval = previous_sleep_interval * 3 or min_retry_interval return min(max_retry_interval, random.randint(min_interval, max_interval))