Как в режиме реального времени обновлять диаграмму боке в приложении для колб при каждом изменении данных? - PullRequest
Новая
       18

Как в режиме реального времени обновлять диаграмму боке в приложении для колб при каждом изменении данных?

0 голосов
/ 29 января 2019

Если у меня есть колба с парой диаграмм, сделанных из боке, как мне обновлять диаграмму в реальном времени, пока она находится в браузере, когда новые данные добавляются или изменяются?Я новичок в bokeh и читаю документацию о том, что мне нужно запустить сервер bokeh, я до сих пор не понимаю, что я должен добавить в свой код, чтобы он обновился.

1 Ответ

0 голосов
/ 30 марта 2019

Это серверное приложение Bokeh с обратным вызовом, выполняемым каждые 1с , и данные обновляются каждые 5с .Глядя на текущую длину plot_data и сравнивая ее с last_data_length, давайте определим, когда нам нужно обновить график (код работает для Bokeh v1.0.4) 

import random, time
from tornado.ioloop import IOLoop
from bokeh.server.server import Server
from bokeh.application import Application
from bokeh.application.handlers.function import FunctionHandler
from bokeh.plotting import figure, ColumnDataSource
from threading import Thread

class BokehApp():
    plot_data = []
    last_data_length = None

    def __init__(self):
        thread = Thread(target = self.startDataAcquisition)
        thread.start()

        io_loop = IOLoop.current()
        server = Server(applications = {'/myapp': Application(FunctionHandler(self.make_document))}, io_loop = io_loop, port = 5001)
        server.start()
        server.show('/myapp')
        io_loop.start()

    def startDataAcquisition(self):
        while True:
            self.plot_data.append({'x': [random.random()], 'y': [random.random()], 'color': [random.choice(['red', 'blue', 'green'])]})
            time.sleep(5)

    def make_document(self, doc):
        source = ColumnDataSource({'x': [], 'y': [], 'color': []})
        fig = figure(title = 'Streaming Circle Plot!', sizing_mode = 'scale_both')
        fig.circle(source = source, x = 'x', y = 'y', color = 'color', size = 10)

        def update():
            if self.last_data_length is not None and self.last_data_length != len(self.plot_data):
                source.stream(self.plot_data[-1])
            self.last_data_length = len(self.plot_data)

        doc.add_root(fig)
        doc.add_periodic_callback(update, 1000)

if __name__ == '__main__':
    app = BokehApp()

Результат:

enter image description here

...