Cómo consultar el estado de la tarea

Los archivos de datos estructurados subidos no crean ni actualizan recursos de forma instantánea. Display & Video 360 puede tardar desde unos segundos hasta horas en procesar tus SDF y realizar las actualizaciones resultantes. Se pueden subir varios archivos de forma simultánea, siempre que no contengan recursos superpuestos.

Precaución: Un solo usuario de Display & Video 360 solo puede procesar 20 tareas de carga de SDF a la vez.

Para determinar si tu tarea finalizó, recupera la operación con regularidad usando sdfuploadtasks.operations.get y verifica si el campo done es True y la tarea finalizó. Este proceso se conoce como "sondeo".

Si la tarea finalizó, se configura el campo response o error. Si el campo error está propagado, la tarea falló y los detalles sobre la falla están disponibles en el objeto Status resultante. Si se completa el campo response, se asignará un SdfUploadTask al campo. Esto significa que Display & Video 360 procesó correctamente el SDF subido. Descarga los archivos de resultados desde la ubicación proporcionada en el campo SdfUploadTask.resourceName.

Una implementación de sondeo ineficiente que verifica un informe de ejecución prolongada consume gran parte de tu cuota de solicitudes a la API. Para limitar los reintentos y conservar la cuota, usa la retirada exponencial.

A continuación, se explica cómo sondear una operación de carga de SDF con una retirada exponencial:

# 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))