Как закрыть соединение Server-Send Events в Flask?

Question

Ниже приведен ответ, используя node.js.

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

Однако, как сделать то же самое в питона термос?

Answer 1

Ну, это зависит от архитектуры вашего приложения.

Позвольте мне показать вам пример (см этот код на 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") 

Колба требующему новое сообщение для Redis (блокировка работы) устойчиво, но когда колба видит, что потоковое заканчивается (StopIteration, если не являются новыми для Python), он возвращается.

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")