如何使用全息视图将数据流式传输到散景服务器

Question

我想将python生成的数据流式传输到网页。我想出了以下示例，使用以下示例
放在一起
https://holoviews.org/user_guide/Streaming_Data.html和

http://holoviews.org/user_guide/Deploying_Bokeh_Apps.html但是我收到文档锁定错误：
"'当我们有文档锁时，_pending_writes应该是非 None，当文档更改时我们应该有锁'"

这是我的例子：

import numpy as np
import holoviews as hv
import holoviews.plotting.bokeh
import streamz
import streamz.dataframe
renderer = hv.renderer('bokeh')
from holoviews import opts
from holoviews.streams import Pipe, Buffer
hv.extension('bokeh')

source_df = streamz.dataframe.Random(freq='5ms', interval='100ms')
sdf = (source_df-0.5).cumsum()
raw_dmap = hv.DynamicMap(hv.Curve, streams=[Buffer(sdf.x)])
smooth_dmap = hv.DynamicMap(hv.Curve, streams=[Buffer(sdf.x.rolling('50ms').mean())])
fig = (raw_dmap.relabel('raw') * smooth_dmap.relabel('smooth')).opts(
    opts.Curve(width=500, show_grid=True))
server = renderer.app(fig, show=True, new_window=True)

页面打开，图形显示，但未更新。在我的笔记本中，我收到以下错误：

tornado.application - ERROR - Exception in callback functools.partial(<function wrap.<locals>.null_wrapper at 0x00000234E3CB9400>, <Future finished exception=RuntimeError('_pending_writes should be non-None when we have a document lock, and we should have the lock when the document changes')>)
Traceback (most recent call last):
  File "C:ProgramDataAnaconda3libsite-packagestornadoioloop.py", line 758, in _run_callback
    ret = callback()
  File "C:ProgramDataAnaconda3libsite-packagestornadostack_context.py", line 300, in null_wrapper
    return fn(*args, **kwargs)
  File "C:ProgramDataAnaconda3libsite-packagestornadoioloop.py", line 779, in _discard_future_result
    future.result()
  File "C:ProgramDataAnaconda3libsite-packagestornadogen.py", line 1147, in run
    yielded = self.gen.send(value)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzdataframecore.py", line 802, in _cb
    yield source._emit((last, now, freq))
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 563, in update
    return self._emit(result)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 563, in update
    return self._emit(result)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 747, in update
    return self._emit(result)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 563, in update
    return self._emit(result)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 563, in update
    return self._emit(result)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 298, in _emit
    r = downstream.update(x, who=self)
  File "C:ProgramDataAnaconda3libsite-packagesstreamzcore.py", line 516, in update
    result = self.func(x, *self.args, **self.kwargs)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsstreams.py", line 436, in send
    self.event(data=data)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsstreams.py", line 375, in event
    self.trigger([self])
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsstreams.py", line 156, in trigger
    subscriber(**dict(union))
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingplot.py", line 615, in refresh
    self._trigger_refresh(stream_key)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingplot.py", line 624, in _trigger_refresh
    self.update(key)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingplot.py", line 596, in update
    item = self.__getitem__(key)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingplot.py", line 261, in __getitem__
    self.update_frame(frame)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingbokehelement.py", line 1944, in update_frame
    self._update_ranges(element, ranges)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingbokehelement.py", line 657, in _update_ranges
    self._shared['x'], self.logx, streaming)
  File "C:ProgramDataAnaconda3libsite-packagesholoviewsplottingbokehelement.py", line 702, in _update_range
    axis_range.trigger(k, old, new)
  File "C:ProgramDataAnaconda3libsite-packagesbokehmodel.py", line 599, in trigger
    super(Model, self).trigger(attr, old, new, hint=hint, setter=setter)
  File "C:ProgramDataAnaconda3libsite-packagesbokehutilcallback_manager.py", line 143, in trigger
    self._document._notify_change(self, attr, old, new, hint, setter, invoke)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentdocument.py", line 1004, in _notify_change
    self._trigger_on_change(event)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentdocument.py", line 1099, in _trigger_on_change
    self._with_self_as_curdoc(invoke_callbacks)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentdocument.py", line 1112, in _with_self_as_curdoc
    return f()
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentdocument.py", line 1098, in invoke_callbacks
    cb(event)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentdocument.py", line 668, in <lambda>
    self._callbacks[receiver] = lambda event: event.dispatch(receiver)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentevents.py", line 244, in dispatch
    super(ModelChangedEvent, self).dispatch(receiver)
  File "C:ProgramDataAnaconda3libsite-packagesbokehdocumentevents.py", line 126, in dispatch
    receiver._document_patched(self)
  File "C:ProgramDataAnaconda3libsite-packagesbokehserversession.py", line 214, in _document_patched
    raise RuntimeError("_pending_writes should be non-None when we have a document lock, and we should have the lock when the document changes")
RuntimeError: _pending_writes should be non-None when we have a document lock, and we should have the lock when the document changes

有什么线索知道我做错了什么吗？亲切问候

Answer 1

我将最后一行更改为renderer.server_doc(fig)，将所有内容保存为名为test.ipynb的笔记本。在命令提示符下，我运行了>bokeh serve --show .test.ipynb.服务器已启动，数据流按预期显示在浏览器中。

import numpy as np
import holoviews as hv
import holoviews.plotting.bokeh
import streamz
import streamz.dataframe
renderer = hv.renderer('bokeh')
from holoviews import opts
from holoviews.streams import Pipe, Buffer
hv.extension('bokeh')

source_df = streamz.dataframe.Random(freq='5ms', interval='100ms')
sdf = (source_df-0.5).cumsum()
raw_dmap = hv.DynamicMap(hv.Curve, streams=[Buffer(sdf.x)])
smooth_dmap = hv.DynamicMap(hv.Curve, streams=[Buffer(sdf.x.rolling('50ms').mean())])
fig = (raw_dmap.relabel('raw') * smooth_dmap.relabel('smooth')).opts(
    opts.Curve(width=500, show_grid=True))
renderer.server_doc(fig)