Lặp lại phát trực tuyến

Khi gọi GoogleAdsService.search_stream, một trình lặp phản hồi truyền trực tuyến sẽ được trả về. Bộ lặp này phải nằm trong cùng phạm vi với ứng dụng GoogleAdsService trong khi được sử dụng để tránh luồng bị hỏng hoặc lỗi phân đoạn. Điều này là do đối tượng Channel gRPC được thu gom rác sau khi đối tượng GoogleAdsService đang mở nằm ngoài phạm vi. Nếu đối tượng GoogleAdsService không còn trong phạm vi tại thời điểm lặp lại xảy ra trên kết quả của search_stream, thì đối tượng Channel có thể đã bị huỷ, gây ra hành vi không xác định khi trình lặp lại cố gắng truy xuất giá trị tiếp theo.

Đoạn mã sau đây minh hoạ cách sử dụng không chính xác trình chuyển đổi luồng:

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

Trong mã trên, đối tượng GoogleAdsService được tạo trong một phạm vi khác với nơi truy cập trình duyệt. Do đó, đối tượng Channel có thể bị huỷ trước khi trình lặp sử dụng toàn bộ phản hồi.

Thay vào đó, trình chuyển đổi tuần tự trực tuyến phải vẫn nằm trong cùng phạm vi với ứng dụng GoogleAdsService, miễn là ứng dụng này đang được sử dụng:

def main(client, customer_id):
    ga_service = client.get_service("GoogleAdsService", version="v19")
    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.