带有Plotly/Dash回调和芹菜/Redis的Django应用

Question

我有一个Django项目，我的一个应用程序使用DASH/PLOTLY提供交互式数据可视化，并将其部署到Heroku。随着我的数据库越来越大，收集相关数据，将其归一化和绘制所需的时间通常大于30秒，因此请求已计时，我的情节不再出现了，这很可悲，因为他们的工作很棒：/

我现在要做的是使用芹菜，以便将数据收集和归一化派遣到工人并不同步地将Redis作为经纪人，但是由于我不这样做，这变得非常困惑在这些框架上有任何经验，我找不到这样的应用程序的示例。 我要在下面发布一个简化且类似的应用程序，而没有任何芹菜物质，这些内容完全可以正常工作（用户提供了种子，并且应用程序绘制了一个散点图，该散点图与从该种子生成的随机数）。

项目树是：

djcel/
    djcel/
    worker/
        dash_apps/
            test_apps/
                plot.py
        templates/
            worker/
                scatter_plot.html
        urls.py
        views.py

主要文件是：

plot.py

from dash import dcc
from dash import html
from dash.dependencies import Input, Output
from django_plotly_dash import DjangoDash
import plotly.graph_objects as go

external_stylesheets = ['https://codepen.io/chriddyp/pen/bWLwgP.css']
app = DjangoDash('ScatterPlot', external_stylesheets=external_stylesheets)

def scatter_plot(seed):
    """
    Plots random data.
    """

    import numpy as np
    np.random.seed(seed=seed)
    x = np.arange(1,1000,1)
    y = np.random.rand(1000)

    fig = go.Figure(data=go.Scatter(x=x, y=y, mode='markers'))
        
    return fig



seeds = [11, 42, 97, 1001]

app.layout = lambda: html.Div([
    html.Div([
        html.Div([
            dcc.Dropdown(
                id='seed',
                options=[{'label': i, 'value': i} for i in seeds],
                placeholder='Select the seed...'
            )
        ],
        style={'width': '30%', 'display': 'inline-block'})
    ]), 
    
    dcc.Graph(id='Scatter-plot'),
])

@app.callback(
    Output('Scatter-plot', 'figure'),
    Input('seed', 'value')
)   
def update_graph(seed):
    if(seed):
        return scatter_plot(seed)
    else:
        return go.Figure() 

views.py

from django.shortcuts import render
from plotly.offline import plot
from django.views.decorators.cache import cache_page

def scatter_plot_dispatch(requests):
    return render(requests, 'worker/scatter_plot.html')

urls.py

from django.urls import path
from . import views
from .dash_apps.test_apps import plot

urlpatterns = [
    path('scatterplot/', views.scatter_plot_dispatch, name="worker.scatter_plot"),
]

scatse_plot.html

{% extends "base.html" %}

{% block content %}
    {% load plotly_dash %}

    <br>
    <div class="{% plotly_class name="ScatterPlot" %} card" style="height:100%; width:100%">
        {% plotly_app name="ScatterPlot" ratio=0.85 %}
    </div>

{% endblock %}

我想不同步运行scate_plot，并在完成任务后使用结果图对象更新了我的视图。我知道如何通过芹菜/Redis发送任务以及如何检查其状态，但是由于Djangodash回调，我正在努力连接这些部件。如何使回调返回一条消息，警告用户可能需要一分钟的时间才能绘制图形，然后在完成任务完成后自动对其进行更新？有什么想法吗？我已经试图弄清楚了一段时间。我很高兴提供任何进一步的信息。谢谢！！