Iteradores de streaming

Ao ligar GoogleAdsService.search_stream, um iterador de resposta de streaming é retornado. Esse iterador deve permanecer no mesmo escopo que o cliente GoogleAdsService durante o uso para evitar fluxos corrompidos ou falhas de segmentação. Isso ocorre porque o objeto Channel do gRPC é coletado da lixeira quando o objeto GoogleAdsService aberto sai do escopo. Se o objeto GoogleAdsService não estiver mais no escopo no momento em que a iteração ocorre no resultado de search_stream, o objeto Channel pode já estar destruídos, causando um comportamento indefinido quando o iterador tenta recuperar o próximo valor.

O código a seguir demonstra o uso incorreto de iteradores de streaming:

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.

No código acima, o objeto GoogleAdsService é criado em um escopo de onde o iterador é acessado. Como resultado, o objeto Channel pode ser destruída antes que o iterador consuma toda a resposta.

Em vez disso, o iterador de streaming deve permanecer no mesmo escopo GoogleAdsService enquanto estiver sendo usado:

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.