Jak wdrożyć wypychanie serwera w ramach Flask?

Question

Próbuję zbudować małą witrynę z funkcjonalnością push serwera na platformie Micro-web Flask, ale nie wiedziałem, czy istnieje framework do bezpośredniej pracy.

Użyłem Juggernaut, ale wygląda na to, że nie działa z redis-py w aktualnej wersji, a Juggernaut został ostatnio przestarzały.

Czy ktoś ma sugestię w mojej sprawie?

Answer 1

Spójrz na Server-Sent Events. Zdarzenia wysyłane z serwera to interfejs API przeglądarki, który umożliwia otwieranie gniazda na serwerze, subskrybowanie strumienia aktualizacji o . Aby uzyskać więcej informacji, przeczytaj artykuł Alexa MacCawa (autor Juggernaut) na why he kills juggernaut i dlaczego łatwiejsze Zdarzenia wysłane z serwera są w zwykłych przypadkach lepszym narzędziem do pracy niż te, które są dostępne w sieci Web: .

Protokół jest naprawdę łatwy. Po prostu dodaj typ MIME text/event-stream do odpowiedzi . Przeglądarka pozostawi otwarte połączenie i będzie nasłuchiwać aktualizacji. Zdarzenie wysłane z serwera jest wierszem tekstu rozpoczynającym się od data: i następującym znakiem nowej linii.

data: this is a simple message 
<blank line> 

Jeśli chcesz wymieniać dane strukturalne, po prostu zrzucić swoje dane jako json i wysłać JSON nad drutu.

Zaletą jest to, że można użyć SSE w kolbie bez potrzeby dodatkowego serwera . Jest prosty chat application example na github, który wykorzystuje redis jako backend pub/sub.

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('/post', methods=['POST']) 
def post(): 
    message = flask.request.form['message'] 
    user = flask.session.get('user', 'anonymous') 
    now = datetime.datetime.now().replace(microsecond=0).time() 
    red.publish('chat', u'[%s] %s: %s' % (now.isoformat(), user, message)) 


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

Nie trzeba używać gunicron uruchomić przykładową aplikację . Wystarczy upewnić się, aby korzystać z wątków podczas uruchamiania aplikacji, ponieważ inaczej połączenie SSE będzie blokować serwer rozwój:

if __name__ == '__main__': 
    app.debug = True 
    app.run(threaded=True) 

Po stronie klienta wystarczy funkcji obsługi Javascript, która zostanie wywołana, gdy nowy wiadomość jest wypychany z serwera.

var source = new EventSource('/stream'); 
source.onmessage = function (event) { 
    alert(event.data); 
}; 

Server-Sent Zdarzenia są supported według najnowszych przeglądarkach Firefox, Chrome i Safari. Internet Explorer nie obsługuje jeszcze Server-Sent Events, ale oczekuje się, aby wspierać ich w wersji 10. Istnieją dwa zalecane Polyfills do obsługi starszych przeglądarek

• EventSource.js
• jquery.eventsource

Answer 2

Jak kontynuacja do @peter-hoffmann's answer, napisałem rozszerzenie Flask specjalnie do obsługi zdarzeń wysyłanych przez serwer. Nazywa się Flask-SSE i jest to available on PyPI.Aby go zainstalować, uruchomić:

$ pip install flask-sse 

Można go używać tak:

from flask import Flask 
from flask_sse import sse 

app = Flask(__name__) 
app.config["REDIS_URL"] = "redis://localhost" 
app.register_blueprint(sse, url_prefix='/stream') 

@app.route('/send') 
def send_message(): 
    sse.publish({"message": "Hello!"}, type='greeting') 
    return "Message sent!" 

I podłączyć do strumienia zdarzeń z javascript, to działa tak:

var source = new EventSource("{{ url_for('sse.stream') }}"); 
source.addEventListener('greeting', function(event) { 
    var data = JSON.parse(event.data); 
    // do what you want with this data 
}, false); 

Documentation is available on ReadTheDocs. Zauważ, że będziesz potrzebować działającego serwera Redis do obsługi pub/sub.