Le Streaming de données avec Python et Flacon

Je n'arrive pas à comprendre comment à l'aide de Flacon de streaming. Voici mon code:

@app.route('/scans/')
def scans_query():
    url_for('static', filename='.*')
    def generate():
        yield render_template('scans.html')
        for i in xrange(50):
            sleep(.5)
            yield render_template('scans.html', **locals())
    return Response(stream_with_context(generate()))

et dans mon template:

<p>{% i %}</p>

Je voudrais voir un compteur sur la page qui change toutes les demi-secondes. Au lieu de cela, le plus proche que j'ai obtenu est de l'impression de la page de chaque numéro sur la ligne suivante.

InformationsquelleAutor Aaron Reba | 2012-11-14
  1. 53

    Pour remplacer le contenu existant sur la page, vous pourriez avoir besoin de javascript c'est à dire, vous pouvez l'envoyer ou de le rendre à en faire la demande pour vous, utilisez le long du scrutin, les websockets, etc. Il y a beaucoup de façons de le faire, en voici une qui utilise serveur d'envoyer des événements:

    #!/usr/bin/env python
import itertools
import time
from flask import Flask, Response, redirect, request, url_for

app = Flask(__name__)

@app.route('/')
def index():
    if request.headers.get('accept') == 'text/event-stream':
        def events():
            for i, c in enumerate(itertools.cycle('\|/-')):
                yield "data: %s %d\n\n" % (c, i)
                time.sleep(.1)  # an artificial delay
        return Response(events(), content_type='text/event-stream')
    return redirect(url_for('static', filename='index.html'))

if __name__ == "__main__":
    app.run(host='localhost', port=23423)

    Où static/index.html:

    <!doctype html>
<title>Server Send Events Demo</title>
<style>
  #data {
    text-align: center;
  }
</style>
<script src="http://code.jquery.com/jquery-latest.js"></script>
<script>
if (!!window.EventSource) {
  var source = new EventSource('/');
  source.onmessage = function(e) {
    $("#data").text(e.data);
  }
}
</script>
<div id="data">nothing received yet</div>

    Le navigateur se reconnecte par défaut dans les 3 secondes si la connexion est perdue. si il n'y a rien de plus à envoyer le serveur peut retourner 404 ou tout simplement l'envoyer certains autres que 'text/event-stream' type de contenu en réponse à la demande suivante. Pour s'arrêter sur le côté client, même si le serveur dispose de plus de données, vous pouvez appeler source.close().

    Remarque: si le flux n'est pas destiné à être infini alors utiliser d'autres techniques (pas de l'ESS), par exemple, d'envoyer des extraits de code javascript pour remplacer le texte (infini <iframe> technique):

    #!/usr/bin/env python
import time
from flask import Flask, Response

app = Flask(__name__)


@app.route('/')
def index():
    def g():
        yield """<!doctype html>
<title>Send javascript snippets demo</title>
<style>
  #data {
    text-align: center;
  }
</style>
<script src="http://code.jquery.com/jquery-latest.js"></script>
<div id="data">nothing received yet</div>
"""

        for i, c in enumerate("hello"):
            yield """
<script>
  $("#data").text("{i} {c}")
</script>
""".format(i=i, c=c)
            time.sleep(1)  # an artificial delay
    return Response(g())


if __name__ == "__main__":
    app.run(host='localhost', port=23423)

    J'ai incorporé le html ici pour montrer qu'il n'y a rien de plus (pas de magie). Ici est le même que ci-dessus mais en utilisant des modèles:

    #!/usr/bin/env python
import time
from flask import Flask, Response

app = Flask(__name__)


def stream_template(template_name, **context):
    # http://flask.pocoo.org/docs/patterns/streaming/#streaming-from-templates
    app.update_template_context(context)
    t = app.jinja_env.get_template(template_name)
    rv = t.stream(context)
    # uncomment if you don't need immediate reaction
    ##rv.enable_buffering(5)
    return rv


@app.route('/')
def index():
    def g():
        for i, c in enumerate("hello"*10):
            time.sleep(.1)  # an artificial delay
            yield i, c
    return Response(stream_template('index.html', data=g()))


if __name__ == "__main__":
    app.run(host='localhost', port=23423)

    Où templates/index.html:

    <!doctype html>
<title>Send javascript with template demo</title>
<style>
  #data {
    text-align: center;
  }
</style>
<script src="http://code.jquery.com/jquery-latest.js"></script>
<div id="data">nothing received yet</div>
{% for i, c in data: %}
<script>
  $("#data").text("{{ i }} {{ c }}")
</script>
{% endfor %}
    • La démo que vous avez fourni (plus précisément je suis en train de jouer avec l'ESS démo) ne fonctionne que pour un seul client. Si j'ouvre une nouvelle fenêtre du navigateur et essayez d'accéder à la page de flux de données, rien ne se passe jusqu'à ce que je fermer ou arrêter la page précédente. Et puis, le compteur commence à 0. Comment voulez-vous retravailler cette sorte que tous les clients d'essayer d'accéder à ce seraient tous voir les mêmes données/compteur, à compter à partir du moment où l'application est commencé? Je suppose que vous auriez à exécuter le comptoir dans un thread séparé, mais je ne suis pas sûr de savoir comment le mettre en œuvre.
    • il y a au moins deux questions: (1) comment prendre en charge plusieurs clients en même temps dans la fiole? — la réponse: de la même manière que vous le faites pour n'importe quel application wsgi par exemple, l'utilisation gunicorn (2) comment donner accès au même compteur pour plusieurs clients? de la même façon que vous fournir un accès aux données partagées dans tout programme de serveur par exemple, en supposant un seul travailleur: définir les iterator et appel next(it) dans la boucle. De toute façon, ce sont des questions distinctes. Poser une nouvelle question spécifique à votre problème particulier.
    • merci JF. J'ai posté une nouvelle question d'une façon plus concentrée ici sur le sujet: stackoverflow.com/questions/33877359/...
    InformationsquelleAutor jfs
  2. 6

    Je pense que si vous allez utiliser des modèles comme ça, vous pourriez avoir besoin d'utiliser la stream_template fonction donnée ici: http://flask.pocoo.org/docs/patterns/streaming/#streaming-from-templates

    Je n'ai pas tester, mais il pourrait ressembler à:

    def stream_template(template_name, **context):
    app.update_template_context(context)
    t = app.jinja_env.get_template(template_name)
    rv = t.stream(context)
    rv.enable_buffering(5)
    return rv

@app.route('/scans/')
def scans_query():
    url_for('static', filename='.*')
    def generate():
        for i in xrange(50):
            sleep(.5)
            yield i
    return Response(stream_template('scans.html', i=generate()))
    • La navigation localhoast:5000/scans avec cette solution donne le message d'erreur suivant sur mon ordinateur: jinja2.exceptions.TemplateSyntaxError: Encountered unknown tag 'i'. des conseils sur comment je peux réussir à le faire fonctionner?
    • Ce code a été écrit en 2012. Je soupçonne plus récente Flacon versions et les versions de Python serait exigent des solutions différentes, ou au moins les changements de syntaxe.
    InformationsquelleAutor aezell