Come si chiude una connessione Server-Invia eventi in Flask?

Question

Di seguito è stata fornita una risposta utilizzando node.js.

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

Tuttavia, come fare la stessa cosa in pitone Flask?

Answer 1

Bene, dipende dall'architettura della tua app.

Lasciate che vi mostri un esempio (si veda il codice a 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 chiede un nuovo messaggio a Redis (operazione di chiusura) costantemente, ma quando Flask vede che termina in streaming (StopIteration, se non sono nuovi a Python), restituisce.

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