程序员最近都爱上了这个网站  程序员们快来瞅瞅吧!  it98k网:it98k.com

本站消息

站长简介/公众号

  出租广告位,需要合作请联系站长

+关注
已关注

分类  

暂无分类

标签  

暂无标签

日期归档  

暂无数据

将数据(超过 1 点)添加到绘图破折号中的现有迹线

发布于2023-11-18 10:23     阅读(9426)     评论(0)     点赞(10)     收藏(0)


我两个都玩过:

https://www.dash-extensions.com/components/event_source

https://github.com/bcliang/dash-extendable-graph/tree/master

当客户端推送新数据时更新跟踪(而不是 dcc.interval)。

server.py

import asyncio
import json
import random
import uvicorn
from sse_starlette import EventSourceResponse
from starlette.applications import Starlette
from starlette.middleware import Middleware
from starlette.middleware.cors import CORSMiddleware

middleware = Middleware(CORSMiddleware, allow_origins=["*"], allow_headers=["*"])
server = Starlette(middleware=[middleware])

async def random_data():
    while True:
        await asyncio.sleep(0.5)
        yield json.dumps([random.random() for _ in range(100)]) 
    

@server.route("/random_data")
async def sse(request):
    generator = random_data()
    return EventSourceResponse(generator)

if __name__ == "__main__":
    uvicorn.run(server, port=5000)

client.py

import dash
from dash import dcc
import dash_bootstrap_components as dbc
from dash_extensions.enrich import html, Output, Input, State
from flask import Flask
import random
from dash_extensions import EventSource

# Start app
server = Flask(__name__)
app = dash.Dash(
    __name__,
    external_stylesheets = [dbc.themes.SPACELAB, dbc.icons.FONT_AWESOME],
    title = 'MT',
    prevent_initial_callbacks = "initial_duplicate"
)


app.layout =  html.Div([
    
    dcc.Graph(
        id='extendablegraph_example',
        figure=dict(
            data=[{'x': [0, 1, 2, 3, 4],
                       'y': [0, .5, 1, .5, 0],
                       'mode':'lines+markers'

                   }],
        )
    ),
    EventSource(id="sse", url="http://127.0.0.1:5000/random_data"),
    html.Div(id='output')
])
      


@app.callback(Output('extendablegraph_example', 'extendData'),
              [Input('sse', 'message')],
              [State('extendablegraph_example', 'figure')])
def update_extend_traces_traceselect(message, existing):
    print(message)
    return (dict(x=[
        [existing['data'][0]['x'][-1] + 1],
    ],
        y=[
        [random.random()],
    ]),
        [0], # trace 0
        20 #20 points total in the trace
    )

    
if __name__ == "__main__":
   app.run_server(debug = True)

这仅适用于 1 点。但是,相反,我想在每次“推送”时(此处每 500 毫秒)更新 10 个点(来自“消息”)。我可以打印这些值update_extendData,因此可以访问它们,但我不知道进一步处理。

在此输入图像描述

刚刚找到了一个不优雅的解决方案来推动 2 点(见下文)。


app.layout =  html.Div([
    
    dcc.Graph(
        id='extendablegraph_example',
        figure=dict(
            data=[{'x': [i for i in range(1, 11)],
                       'y': [0 for _ in range(10)],
                       'mode':'lines+markers'

                   }],
        )
    ),
    EventSource(id="sse", url="http://127.0.0.1:5000/random_data"),
    html.Div(id='output')
])
      


@app.callback(Output('extendablegraph_example', 'extendData'),
              [Input('sse', 'message')],
              [State('extendablegraph_example', 'figure')])
def update_extend_traces_traceselect(message, existing):
    print(existing['data'][0]['x'])
    return (dict(x=[
        [existing['data'][0]['x'][-1] + 1, existing['data'][0]['x'][-1] + 2 * 1],
        
    ],
        y=[
        [random.random(),random.random()],
    ]),
        [0], # trace 0
        10 #20 points total in the trace
    )

解决方案


暂无回答



所属网站分类: 技术文章 > 问答

作者:黑洞官方问答小能手

链接:https://www.pythonheidong.com/blog/article/2039593/489520e42547b1051f1b/

来源:python黑洞网

任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任

10 0
收藏该文
已收藏

评论内容:(最多支持255个字符)