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