5

我正在尝试获取数据的实时图，因为它是由使用 pyqtgraph 的仪器收集的。

数据收集由主进程处理，然后通过连接传递给绘制它的子进程。我只是想传递新数据并在传递新数据时更新它。

我试图通过将读取的连接放在 Qt Timer 更新循环中来实现这一点，但是我很难在连续的更新周期之间传递图形数据（我想附加到它）。我从下面的代码中省略了，但基本上我想加入连续的大量 connData，我认为使用全局会起作用，但由于某种原因我无法在这里实现。

编辑 1：我与 pyqtgraph 示例进行比较的问题似乎是将数据传递给 Qtimer 的更新过程，我得到：

NameError：未定义全局名称“CurveData”

我尝试这样做而不是使用 pyqtgraph 的多处理模块的原因是我不想每次都通过连接传递整个数据集（我认为这是必要的）。谢谢！

编辑 2： 是否有 pyqtgraph.multiprocess 的文档？

（这是提供的原始代码）

import multiprocessing
import numpy as np
from pyqtgraph.Qt import QtCore, QtGui
import pyqtgraph as pg
import pyqtgraph.opengl as gl
import sys
import os

def MakeGraph(conn):

    win = pg.GraphicsWindow(title = "test")
    win.resize(300,300)

    p1 = win.addPlot(title = "test")

    curve = p1.plot(pen = 'y')
    timer = QtCore.QTimer()

    def Update():
        try:
            ConnData = conn.recv()
            ConnData = [float(i) for i in ConnData]
            curve.setData(ConnData)
        except EOFError:
            print "Graph connection closed\n"
            timer.stop()
            QtGui.QApplication.quit()

    timer.timeout.connect(Update)
    timer.start(0)

    if (sys.flags.interactive != 1) or not hasattr(QtCore, 'PYQT_VERSION'):
            QtGui.QApplication.instance().exec_()

修改版：

import multiprocessing
import numpy as np
from pyqtgraph.Qt import QtCore, QtGui
import pyqtgraph as pg
import pyqtgraph.opengl as gl
import sys
import os

def MakeGraph(conn):

    win = pg.GraphicsWindow(title = "test")
    win.resize(300,300)

    p1 = win.addPlot(title = "test")

    curve = p1.plot(pen = 'y')
    timer = QtCore.QTimer()
    CurveData = []

    def Update():
        global CurveData
        try:
            ConnData = conn.recv()
            ConnData = [float(i) for i in ConnData]
            CurveData = np.append(CurveData,ConnData)
            curve.setData(CurveData)
        except EOFError:
            print "Graph connection closed\n"
            timer.stop()
            QtGui.QApplication.quit()

    timer.timeout.connect(Update)
    timer.start(0)

    if (sys.flags.interactive != 1) or not hasattr(QtCore, 'PYQT_VERSION'):
            QtGui.QApplication.instance().exec_()
4

1 回答 1

10

您还没有解释发布的示例有什么不起作用。有错误信息吗？进程是否无法接收消息？情节结果是否与您的预期有所不同？

作为最初的答案，我将推荐一种不同的方法：使用 pyqtgraph 的内置多处理功能。如果您从主进程运行此代码，它将为您提供绘图窗口和在新进程中运行的曲线的代理。您在代理上调用的任何方法都将转发到远程进程：

import pyqtgraph as pg
pg.mkQApp()

# Create remote process with a plot window
import pyqtgraph.multiprocess as mp
proc = mp.QtProcess()
rpg = proc._import('pyqtgraph')
plotwin = rpg.plot()
curve = plotwin.plot(pen='y')

# create an empty list in the remote process
data = proc.transfer([])

# Send new data to the remote process and plot it
# We use the special argument _callSync='off' because we do
# not want to wait for a return value.
data.extend([1,5,2,4,3], _callSync='off')
curve.setData(y=data, _callSync='off')

请注意，我们在这里创建的所有对象——rpg、plotwin、curve 和 data——都是远程进程中真实对象的代理。因此，您可以使用通常的 pyqtgraph 类执行的几乎所有操作也可以使用这些对象完成，并且结果将出现在远程进程中。例如：

# Local code:
win = pg.GraphicsWindow()
p1 = win.addPlot()
p2 = win.addPlot()

# Remote code:
win = rpg.GraphicsWindow()
p1 = win.addPlot()
p2 = win.addPlot()

这两个示例的唯一区别是起点——pg 用于本地 pyqtgraph 模块，而 rpg 用于远程模块。

于 2013-07-30T17:07:49.267 回答