Потоковые итераторы

При вызове GoogleAdsService.search_stream возвращается итератор потокового ответа. Этот итератор должен оставаться в той же области действия, что и клиент GoogleAdsService , во время использования, чтобы избежать разрывов потоков или ошибок сегментации. Это связано с тем, что объект gRPC Channel удаляется сборщиком мусора после выхода открытого объекта GoogleAdsService из области действия. Если к моменту итерации по результату search_stream объект GoogleAdsService уже не находится в области действия, объект Channel может быть уже уничтожен, что приведет к неопределенному поведению при попытке итератора получить следующее значение.

Следующий код демонстрирует неправильное использование потоковых итераторов:

def stream_response(client, customer_id, query):
    return client.get_service("GoogleAdsService", version="v20").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="v20")
    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.