При вызове GoogleAdsService.search_stream возвращается итератор ответа потоковой передачи. Во время использования этот итератор должен оставаться в той же области, что и клиент GoogleAdsService , чтобы избежать прерывания потоков или ошибок сегментации. Это связано с тем, что объект gRPC Channel подвергается сборке мусора, как только открытый объект GoogleAdsService выходит за пределы области действия. Если к моменту итерации результата search_stream объект GoogleAdsService больше не находится в области видимости, объект Channel может быть уже уничтожен, что приводит к неопределенному поведению, когда итератор пытается получить следующее значение.
Следующий код демонстрирует неправильное использование потоковых итераторов:
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.
В приведенном выше коде объект GoogleAdsService создается в области, отличной от той, в которой осуществляется доступ к итератору. В результате объект Channel может быть уничтожен до того, как итератор обработает весь ответ.
Вместо этого итератор потоковой передачи должен оставаться в той же области, что и клиент GoogleAdsService , пока он используется:
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.