ssepulveda / rtgraph

A simple Python application for plotting and storing data in real time

RTGraph

A simple Python application for plotting and storing data from a serial port in real time, formatted as CSV. The application uses the mutliprocessing package to allow better usage of the host resources, overcoming limitations such as GIL in Python.

Dependencies

• Python 3 (3.2 or later).
• PyQt5.
• PySerial.
• PyQtGraph.

Installation instructions

Using Anaconda or Miniconda (Windows, macOS, Linux)

1. Install Anaconda or Miniconda. Remember to add conda to your path.
2. Open a terminal and type:
   • conda install pyqtgraph pyserial

Using Pip (Windows, macOS, Linux)

1. Verify you have installed pip.
2. Open a terminal and type:
   • pip install PyQt5 pyqtgraph pyserial

Linux (Apt based distros)

1. Open a terminal and type:
   • sudo apt-get install python3-pyqt5 python3-pyqtgraph python3-serial

Usage

From a terminal, on the root folder of the project, run:

• python -m rtgraph

Links

• Presentation on SciPy 2015
• Proceedings on SciPy 2015

License and Citations

The project is distributed under MIT License. A DOI is attached to the project for citations.

rtgraph's Issues

Spectrogram / waterfall type visualization

Hi there,
I'm investigating how to build a simple spectrogram / waterfall type visualization.
It seems that RTGraph could be adapted to provided this functionality.
However, the visualization that needs to be obtained at the end is more a 2D image than 1D signals as shown in the talk and proceedings.

Do you think it would be possible to implement such a visualization using RTGraph? If so, could you point me to some relevant links regarding this?

Thank you for sharing this project.
Best regards,
Florian

missing installation instructions

Could you please provide installation instructions (ideally for different platforms)?

TypeError: can't pickle weakref objects when running demo in Simulator mode

Hi! I tried to run your demo in Simulator mode, but this error occurred after start.
Here is the traceback:

Traceback (most recent call last):  
  File "D:\ProgramData\Anaconda3\lib\site-packages\rtgraph\ui\mainWindow.py", line 62, in start  
    if self.worker.start():  
  File "D:\ProgramData\Anaconda3\lib\site-packages\rtgraph\core\worker.py", line 80, in start  
    self._acquisition_process.start()  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\process.py", line 112, in start  
    self._popen = self._Popen(self)  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\context.py", line 223, in _Popen  
    return _default_context.get_context().Process._Popen(process_obj)  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\context.py", line 322, in _Popen  
    return Popen(process_obj)  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\popen_spawn_win32.py", line 65, in __init__  
    reduction.dump(process_obj, to_child)  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\reduction.py", line 60, in dump  
    ForkingPickler(file, protocol).dump(obj)  
TypeError: can't pickle weakref objects  
Traceback (most recent call last):  
  File "<string>", line 1, in <module>  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\spawn.py", line 105, in spawn_main  
    exitcode = _main(fd)  
  File "D:\ProgramData\Anaconda3\lib\multiprocessing\spawn.py", line 115, in _main  
    self = reduction.pickle.load(from_parent)  
EOFError: Ran out of input

I found out that this error occurred because self._parser_process.start() is called before self._acquisition_process.start()

And here is my simulated program where the same error occurs:

from multiprocessing import Process,Event
import time
class TestProcess(Process):
    def __init__(self):
        Process.__init__(self)
        self._exit=Event()
    def stop(self):
        self._exit.set()
    def run(self):
        while not self._exit.is_set():
            pass
class TestProcessB(TestProcess):
    def __init__(self,p):
        Process.__init__(self)
        self._test_process=p
    def run(self):
        while not self._exit.is_set():
            print(time.time())
            time.sleep(1)
if __name__=='__main__':
    tp=TestProcess()
    tpb=TestProcessB(tp)
    tp.start()
    tpb.start()
    time.sleep(10)
    tp.stop()
    tpb.stop()

How can this problem be fixed?