INNER CODE UNIT · Python

stream_logs

Delta-F/deltafstation · backend/app.py:133

    def stream_logs():
        """日志实时流（SSE）。

        前端通过 EventSource 或 fetch 流式读取该接口，以获得后台日志增量。
        """
        def generate():
            """生成 SSE 数据流。"""
            # 建立连接时先发送一个欢迎消息
            yield "data: [SYSTEM] Log stream connected...\n\n"
            while True:
                logs = global_log_queue.get_all()
                for log in logs:
                    # SSE 格式必须以 data: 开头，并以 \n\n 结束
                    yield f"data: {log}\n\n"
                time.sleep(0.5)
        return Response(generate(), mimetype='text/event-stream')
    
    @app.errorhandler(404)

View source record →