Ao chamar
GoogleAdsService.search_stream,
um iterador de resposta de streaming é retornado. Esse iterador precisa permanecer no
mesmo escopo do cliente GoogleAdsService enquanto é usado para evitar
fluxos corrompidos ou falhas de segmentação. Isso ocorre porque o objeto Channel do gRPC
é coletado quando o objeto GoogleAdsService aberto sai do escopo.
Se o objeto GoogleAdsService não estiver mais no escopo quando a iteração
ocorrer no resultado de search_stream, o objeto Channel já poderá ter sido
destruído, causando um comportamento indefinido quando o iterador tentar 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="v18").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 diferente
de onde o iterador é acessado. Como resultado, o objeto Channel pode
ser destruído antes que o iterador consuma toda a resposta.
Em vez disso, o iterador de streaming precisa permanecer no mesmo escopo que o
cliente GoogleAdsService enquanto estiver sendo usado:
def main(client, customer_id):
ga_service = client.get_service("GoogleAdsService", version="v18")
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.