如何关闭Flask中的服务器发送事件连接？ [英] How do I close a Server-Send Events connection in Flask?

问题描述

下面给出了一个使用node.js的答案。

如何关闭服务器上的服务器发送的事件连接？

然而，如何在python Flask中做同样的事情呢？

解决方案

让我给你看一个例子（见 ） app.pyrel =nofollow> https://github.com/jkbr/chat/blob/master/app.py ）：

<$ p （）：
pubsub.subscribe（'chat'）
用于pubsub.listen（）中的消息：$ b $ pubsub.subscribe（'chat'）
pubsub = red.pubsub
print message
yield'data：％s\\\
\\\
'％message ['data']

@ app.route（'/ stream'）
def stream（）：
return flask.Response（event_stream（），
mimetype =text / event-stream）

Flask向Redis发送一条新消息（锁定操作）稳定的，但是当Flask看到流终止时（ StopIteration ，如果你不是Python的新手），它会返回。

  def event_stream（）：
 pubsub = red.pubsub（）
 pubsub.subscribe（'chat'）
在pubsub.listen （）：
 if i_should_close_the_connection：
 break 
 yield'data：％s\\\
\\\
'％message ['data'] 
 
 @app。 route（'/ stream'）
 def stream（）：
 return flask.Response（event_stream（），
 mimetype =text / event-stream）
  

The below has given an answer using node.js.

How to close a "Server-Sent Events"-connection on the server?

However, how to do the same thing in python Flask?

解决方案

Well, it depends on the architecture of your app.

Let me show you an example (see this code at https://github.com/jkbr/chat/blob/master/app.py):

def event_stream():
    pubsub = red.pubsub()
    pubsub.subscribe('chat')
    for message in pubsub.listen():
        print message
        yield 'data: %s\n\n' % message['data']

@app.route('/stream')
def stream():
    return flask.Response(event_stream(),
                          mimetype="text/event-stream")

Flask asks a new message to Redis (locking operation) steadily, but when Flask sees that streaming terminates (StopIteration, if you aren't new to Python), it returns.

def event_stream():
    pubsub = red.pubsub()
    pubsub.subscribe('chat')
    for message in pubsub.listen():
        if i_should_close_the_connection:
            break
        yield 'data: %s\n\n' % message['data']

@app.route('/stream')
def stream():
    return flask.Response(event_stream(),
                          mimetype="text/event-stream")

这篇关于如何关闭Flask中的服务器发送事件连接？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！