Iteradores de transmisión

Al realizar llamadas GoogleAdsService.search_stream: se muestra un iterador de respuesta de transmisión. Este iterador debe permanecer mismo alcance que el cliente GoogleAdsService mientras se usa para evitar transmisiones rotas o fallas de segmentación. Esto se debe a que el objeto Channel de gRPC se recoge elementos no utilizados una vez que el objeto GoogleAdsService abierto queda fuera del alcance. Si el objeto GoogleAdsService ya no está dentro del alcance en el momento en que la iteración se produce en el resultado de search_stream, es posible que el objeto Channel ya esté y destruyen, lo que causa un comportamiento indefinido cuando el iterador intenta recuperar el el valor siguiente.

En el siguiente código, se demuestra el uso incorrecto de iteradores de transmisión:

def stream_response(client, customer_id, query):
    return client.get_service("GoogleAdsService", version="v22").search_stream(customer_id, query=query)

def main(client, customer_id):
    query = "SELECT campaign.name FROM campaign LIMIT 10"
    response = stream_response(client, customer_id, query=query)
    # Access the iterator in a different scope from where the service object was created.
    try:
        for batch in response:
            # Iterate through response, expect undefined behavior.

En el código anterior, el objeto GoogleAdsService se crea dentro de otro desde donde se accede al iterador. Como resultado, el objeto Channel puede antes de que el iterador consuma toda la respuesta.

En su lugar, el iterador de transmisión debe permanecer en el mismo alcance que Cliente GoogleAdsService durante el tiempo en que se use:

def main(client, customer_id):
    ga_service = client.get_service("GoogleAdsService", version="v22")
    query = "SELECT campaign.name FROM campaign LIMIT 10"
    response = ga_service.search_stream(customer_id=customer_id, query=query)
    # Access the iterator in the same scope as where the service object was created.
    try:
        for batch in response:
            # Successfully iterate through response.