Podczas wywoływania GoogleAdsService.search_stream zwracany jest iterator odpowiedzi strumieniowania. Ten iterator powinien pozostawać w tym samym zakresie co klient GoogleAdsService podczas używania, aby uniknąć przerw w strumieniach lub błędów podziału na segmenty. Wynika to z tego, że po wyjściu z zakresu otwarty obiekt GoogleAdsService obiekt gRPC Channel jest usuwany do kosza.
Jeśli obiekt GoogleAdsService zostanie usunięty z zakresu do momentu wystąpienia iteracji wynikającego z wyniku search_stream, obiekt Channel może już zostać zniszczony, co spowoduje niezdefiniowane zachowanie, gdy iterator próbuje pobrać następną wartość.
Ten kod obrazuje nieprawidłowe używanie iteratorów strumieniowania:
def stream_response(client, customer_id, query):
return client.get_service("GoogleAdsService", version="v16").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.
W powyższym kodzie obiekt GoogleAdsService jest tworzony w innym zakresie niż zapewniany dostęp do iteratora. W związku z tym obiekt Channel może zostać zniszczony, zanim iterator wykorzysta całą odpowiedź.
Zamiast tego iterator strumieniowania powinien pozostawać w tym samym zakresie co klient GoogleAdsService tak długo, jak jest używany:
def main(client, customer_id):
ga_service = client.get_service("GoogleAdsService", version="v16")
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.