Function stream_logs

examples/pod_logs_non_blocking.py:17–41

()

def stream_logs():
    config.load_kube_config()
    v1 = client.CoreV1Api()

    resp = v1.read_namespaced_pod_log(
        name="log-demo",
        namespace="default",
        follow=True,
        _preload_content=False
    )

    # 👇 make socket non-blocking with timeout
    resp._fp.fp.raw._sock.settimeout(1)

    try:
        while not stop_event.is_set():
            try:
                data = resp.read(1024)
                if data:
                    print(data.decode(), end="")
            except (socket.timeout, ReadTimeoutError):
                continue
    finally:
        resp.close()
        print("\nLog streaming stopped cleanly.")


t = threading.Thread(target=stream_logs)