Мониторинг потока данных в реальном времени с помощью флеш-веб-приложения

4 David Marx [2015-11-23 23:40:00]

Это основано на ответе, опубликованном в qaru.site/questions/147215/...

Я хотел бы отслеживать поток данных и подталкивать его к интерфейсу, аналогичному приведенному выше ответу, но где поток начинает генерировать/контролировать данные, как только приложение запускается, и клиент всегда видит текущий состояние потока данных (который продолжает работать независимо от того, запрашивают ли они данные с сервера).

Я уверен, что мне нужно отделить поток данных от front-end через потоки, но я не очень практикован с потоковым/асинхронным программированием и считаю, что я делаю это неправильно. Может быть, вместо threading мне нужно использовать многопроцессорность? Здесь примерно то, что я пытаюсь сделать (измененный из ответа, связанного выше):

app.py

#!/usr/bin/env python
from __future__ import division
import itertools
import time
from flask import Flask, Response, redirect, request, url_for
from random import gauss
import threading

app = Flask(__name__)

# Generate streaming data and calculate statistics from it
class MyStreamMonitor(object):
    def __init__(self):
        self.sum   = 0
        self.count = 0
    @property
    def mu(self):
        try:
            outv = self.sum/self.count
        except:
            outv = 0
        return outv
    def generate_values(self):
        while True:
            time.sleep(.1)  # an artificial delay
            yield gauss(0,1)
    def monitor(self, report_interval=1):
        print "Starting data stream..."
        for x in self.generate_values():
            self.sum   += x
            self.count += 1 

stream = MyStreamMonitor()

@app.route('/')
def index():
    if request.headers.get('accept') == 'text/event-stream':
        def events():
            while True:
                yield "data: %s %d\n\n" % (stream.count, stream.mu)
                time.sleep(.01) # artificial delay. would rather push whenever values are updated. 
        return Response(events(), content_type='text/event-stream')
    return redirect(url_for('static', filename='index.html'))

if __name__ == "__main__":
    # Data monitor should start as soon as the app is started.
    t = threading.Thread(target=stream.monitor() )
    t.start()
    print "Starting webapp..." # we never get to this point.
    app.run(host='localhost', port=23423)

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>

Этот код не работает. Сообщение "Starting webapp..." никогда не печатается, равно как и обычные сообщения об флажках и посещение обслуживаемого URL-адреса не подтверждают, что приложение не работает.

Как заставить монитор данных работать в фоновом режиме таким образом, чтобы флажок мог получить доступ к значениям, которые он видит, и подтолкнуть текущее состояние к клиенту (лучше даже: до тех пор, пока клиент слушает, нажмите текущее состояние при изменении соответствующих значений)?

python multithreading flask stream network-programming

Оригинал вопроса (на английском)

3 Решение David Marx [2015-12-12 00:57:00]

Мне просто нужно было изменить эту строку

t = threading.Thread(target=stream.monitor())

:

t = threading.Thread(target=stream.monitor)

Оригинал ответа (на английском)

Мониторинг потока данных в реальном времени с помощью флеш-веб-приложения

1 ответ