django 流式输出示例

在Django框架中，流式输出（Streaming Response）允许你在不一次性加载整个页面内容到内存的情况下发送响应。这在处理大量数据、生成动态内容或者需要分块传输文件时非常有用。下面是一个简单的流式输出示例，我们将创建一个无限滚动的博客列表：

from django.http import StreamingHttpResponse
from itertools import islice

# 假设我们有一个BlogPost模型
def infinite_blog_list(request):
    # 获取所有文章，这里仅为了演示，实际应用可能需要查询数据库
    all_posts = BlogPost.objects.all()

    def generate():
        for post in all_posts:
            yield f'<li>{post.title}</li>\n'

    response = StreamingHttpResponse(generate(), content_type='text/html')
    response['Content-Length'] = '0'  # 告诉浏览器响应长度未知，会一直读取
    response['X-Accel-Buffering'] = 'no'  # 防止浏览器缓存

    return response

相关问题

django sse

### 实现 Django 中的服务器发送事件 (SSE)

为了在 Django 中实现服务器发送事件(SSE)，可以利用 `django-eventstream` 或者更基础的方式通过视图函数直接处理 SSE 连接。下面介绍一种基于 `django-eventstream` 的方式。

#### 安装依赖

首先安装必要的 Python 包：

pip install django-eventstream

#### 修改配置文件 settings.py

确保在 `INSTALLED_APPS` 列表中加入 `'django_eventstream'`:

INSTALLED_APPS = [
    ...
    'django_eventstream',
]

还需要设置允许跨域资源共享(CORS)以便前端能够接收来自不同域名的数据流，如果前后端同源则不需要此步操作。

#### 设置 URL 路由

编辑项目的 `urls.py` 文件以包含 `django_eventstream.urls` 提供的路由模式[^1]:

from django.urls import path, include

urlpatterns = [
    ...
    path('events/', include('django_eventstream.urls')),
]

#### 创建并发送事件

可以通过调用 API 来创建新事件并向所有连接客户端广播消息。这通常是在某些业务逻辑发生之后完成的操作。例如，在模型保存后触发信号来通知订阅者有新的更新可用。

假设有一个简单的视图用于手动测试发布事件的功能：

from django.http import JsonResponse
import json
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

def send_test_event(request):
    channel_layer = get_channel_layer()
    message = {"message": "This is a test event"}
    
    # 向名为 'room-name' 的房间内的所有人发送消息
    async_to_sync(channel_layer.group_send)(
        'room-name', {
            'type': 'send_message',
            'text': json.dumps(message),
        }
    )
    
    return JsonResponse({"status": "Event sent"})

请注意上述例子使用了 Channels 库来进行 WebSocket 和异步支持；对于纯 HTTP 流式的 SSE 场景来说并不严格必要，这里仅作为示范说明如何集成到更大的实时通信架构里去。

#### 前端监听事件

最后一步就是在 HTML 页面上添加 JavaScript 代码片段用来建立与服务端之间的持久化连接，并监听传入的消息：

<script>
const source = new EventSource('/events/');
source.onmessage = function(event) {
    console.log(`New message: ${event.data}`);
};
</script>

以上就是完整的 Django SSE 示例教程，展示了从环境搭建、路径配置直到实际应用开发的过程[^2]。

django中什么是StreamingHttpResponse

在 Django 中，`StreamingHttpResponse` 是一个响应，用于处理需要流式传输的响应数据。通常，当响应数据比较大或者需要长时间生成时，使用 `StreamingHttpResponse` 可以避免将整个响应数据保存在内存中，并且可以在生成响应数据的同时开始向客户端传输数据，从而提高响应速度和降低内存占用。

使用 `StreamingHttpResponse` 的步骤如下：

1. 定义一个生成器函数，用于逐步生成响应数据。
2. 在视图函数中实例化 `StreamingHttpResponse` 对象，并将生成器函数作为参数传入。
3. 在生成器函数中使用 `yield` 语句逐步生成响应数据。
4. 在视图函数中返回 `StreamingHttpResponse` 对象。

以下是一个使用 `StreamingHttpResponse` 的示例：

from django.http import StreamingHttpResponse

def stream_response(request):
    def generate_data():
        for i in range(10):
            yield str(i).encode('utf-8')
    
    response = StreamingHttpResponse(generate_data())
    response['Content-Type'] = 'text/plain'
    return response

在上面的示例中，我们定义了一个生成器函数 `generate_data()`，用于生成响应数据。然后，在视图函数 `stream_response()` 中，我们实例化了一个 `StreamingHttpResponse` 对象，并将 `generate_data()` 函数作为参数传入。最后，我们设置了响应的内容类型，并返回 `StreamingHttpResponse` 对象。

注意，生成器函数必须逐步生成响应数据，并使用 `yield` 语句将数据返回给 `StreamingHttpResponse` 对象。否则，数据将无法逐步传输到客户端。