python - 如何使用Python(Django)进行SSE？

我有两个不同的页面，一个(A)显示从模型对象获取的数据，另一个(B)更改其字段。
我希望将发布数据从B发送到服务器时，服务器更改A中的值。
最好的方法是什么？

这个例子可能对我有用，但是它在PHP中...有一种方法可以用Python复制它吗？
https://www.w3schools.com/html/html5_serversentevents.asp

最佳答案

这是Django中w3schools的有效示例:

模板

<!DOCTYPE html>
<html>
<body>

<h1>Getting server updates</h1>
<div id="result"></div>

<script>
if(typeof(EventSource) !== "undefined") {
  var source = new EventSource("stream/");
  source.onmessage = function(event) {
    document.getElementById("result").innerHTML += event.data + "<br>";
  };
} else {
  document.getElementById("result").innerHTML = "Sorry, your browser does not support server-sent events...";
}
</script>

</body>
</html>

意见

import datetime
import time
from django.http import StreamingHttpResponse

def stream(request):
    def event_stream():
        while True:
            time.sleep(3)
            yield 'data: The server time is: %s\n\n' % datetime.datetime.now()
    return StreamingHttpResponse(event_stream(), content_type='text/event-stream')

网址

urlpatterns = [
    path('stream/', views.stream, name='stream')
]

更新:

如果要管理通知，可以创建如下模型:

from django.db import models

class Notification(models.Model):
    text = models.CharField(max_length=200)
    user = models.ForeignKey(User, on_delete=models.CASCADE)
    sent = models.BooleanField(default=False)

然后创建查找第一个未发送的通知的 View 并将其发送:

@login_required
def stream(request):
    def event_stream():
        while True:
            time.sleep(3)
            notification = Notification.objects.filter(
                sent=False, user=request.user
            ).first()

            text = ''

            if notification:
                text = notification.text
                notification.sent = True
                notification.save()

            yield 'data: %s\n\n' % text

    return StreamingHttpResponse(event_stream(), content_type='text/event-stream')

以及在send_notification模型中创建条目的Notification函数(只需从代码中的任何位置调用此函数):

def send_notification(user, text):
    Notification.objects.create(
        user=user, text=text
    )

就是这样，很简单。

用python

python - 如何使用Python(Django)进行SSE？