util.labjack.LabJackStream is a class that handles streaming data from LabJack UD-series devices to LabStreamingLayer, though it has currently only been tested on the U6. (Update: apparently, it currently only works with the U6, but it can easily be modified for other devices. I'll fix this in the future, but until then, please refer to this issue if you want to use another UD device.)
You can just drop the util.labjack module into your project and import LabJackStream to use. You'll need some dependencies installed, namely pylsl, liblsl, numpy, LabJackPython, and the appropriate driver for your LabJack device. An example environment is in environment.yml
Then, you can start a stream as follows:
from util.labjack import LabJackStream
ljs = LabJackStream(n_channels = 4, sfreq = 10000)
ljs.stream_data()
which can then be stopped by interrupting the Python process. Whatever number of channels you choose for n_channels will always pick the first n channels, which should start with the analog input channels. It currently assumes all input channels are analog, which I assume will cause it to fail if n_channels exceeds the number of available analog channels because of how channel data is accessed (by name) through LabJack's Python API. Maybe I'll fix this in the future, but for now this is a limitation.
By default, it will try to initialize a U6 device, which will obviously fail if you aren't using U6 hardware. You can specify another device class from the LabJackPython library by passing it as device_class when you initialize LabJackStream.
from u3 import U3
ljs = LabJackStream(n_channels = 2, sfreq = 2000, device_class = U3)
ljs.stream_data()
Of course, you probably will want to do something else with your Python process in the meantime, in which case you should call stream_data in another thread.
import threading
ljs = LabJackStream(n_channels = 4, sfreq = 10000)
ljs_thread = threading.Thread(target = ljs.stream_data)
ljs_thread.start()
# other code goes here...
# clean up when you're done
ljs.stop_stream()
ljs_thread.join()
In testing, I couldn't go up to the maximal sampling rate from the LabJack U6's documentation without dropping samples. But I got almost there e.g. 10 kHz for four analog input channels instead of the advertised 12 kHz.
In old versions of pylsl, an error would be thrown when trying to call pylsl commands from a thread (other than the main thread) on Linux. Evidently, this has since been fixed -- so if you have this problem, you may just have to update your pylsl version.