python - 一起运行两个 Python 应用程序？

Question

我想创建一个 Python 应用程序，在 Dash 应用程序上检索一些数据并绘制图表。

这是 Dash 部分。这是我的全部数据将被发送并显示在网页上的地方，因为我现在就开始，这只是实时图表的基本示例。

import dash
from dash.dependencies import Output, Event
import dash_core_components as dcc
import dash_html_components as html
import plotly
import random
import plotly.graph_objs as go
from collections import deque

app = dash.Dash(__name__)
app.layout = html.Div(
    [
        dcc.Graph(id='live-graph', animate=True),
        dcc.Interval(
            id='graph-update',
            interval=1*1000
        ),
    ]
)

@app.callback(Output('live-graph', 'figure'),
              events=[Event('graph-update', 'interval')])
def update_graph_scatter():
    X.append(X[-1]+1)
    Y.append(Y[-1]+Y[-1]*random.uniform(-0.1,0.1))

    data = plotly.graph_objs.Scatter(
            x=list(X),
            y=list(Y),
            name='Scatter',
            mode= 'lines+markers'
            )

    return {'data': [data],'layout' : go.Layout(xaxis=dict(range=[min(X),max(X)]),
                                                yaxis=dict(range=[min(Y),max(Y)]),)}

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

这是检索数据的 Python 部分，连接到 Websocket。

import websocket
import json
from bitmex_websocket import Instrument
from bitmex_websocket.constants import InstrumentChannels
from bitmex_websocket.constants import Channels

websocket.enableTrace(True)

channels = [
    InstrumentChannels.trade,
]

XBTUSD = Instrument(symbol='XBTUSD',
                    channels=channels)
XBTUSD.on('action', lambda msg: test(msg))

XBTUSD = Instrument(symbol='XBTUSD',                       
                channels=channels)

XBTUSD.on('action', lambda msg: rekter(msg))

def rekter(msg):

    if msg['table'] =='trade':
        Rate = msg['data'][0]['price']

        print(Rate)


XBTUSD.run_forever()

现在第二部分应该只将 rate 发送到图表，但将来我希望它每秒处理更多的数据，并且我愿意与Pandas 和 Numpy 来处理这些数据。

我的问题是我不知道如何将我的第二部分“嵌入”到第一部分中。我尝试这样做，但如果我将行XBTUSD.run_forever()放在app.run_server(debug=True)之前，则只会执行代码的一部分，并且我的在我停止代码的第一部分之前，整个 Dash 应用程序不会运行。如果我做相反的事情，也会发生同样的情况。是否可以同时运行两者？或者我应该寻找另一种方式？

Answer 1

您可能并不真的想将其“嵌入”到第一个中。据我所知，第二个仅将数据“注入(inject)”到第一个，因此没有逻辑需要将它们放在一起，并且从架构设计方面来看，耦合组件会产生麻烦。

我建议只从 shell 运行两个脚本。当然，您可以使用包装器通过一个脚本启动两者，例如

import subprocess

p = subprocess.Popen(['python', 'hello.py'])
p = subprocess.Popen(['python', 'wolrd.py'])

p.wait()