Làm cách nào để đóng kết nối Sự kiện-Gửi sự kiện trong Flask?

Question

Bên dưới đã đưa ra câu trả lời bằng cách sử dụng node.js.

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

Tuy nhiên, làm thế nào để làm điều tương tự trong python Flask?

Answer 1

Vâng, tùy thuộc vào kiến ​​trúc của ứng dụng của bạn.

Hãy để tôi chỉ cho bạn một ví dụ (xem mã này ở 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 hỏi một tin nhắn mới để Redis (khóa hoạt động) đều đặn, nhưng khi Flask thấy rằng chấm dứt truyền trực tuyến (StopIteration, nếu bạn không phải là mới đối với Python), nó trả về.

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