REIP - data processing pipelines

Install

# while we're still private:
git clone https://github.com/reip-project/reip-pipelines.git
pip install -e ./reip-pipelines

# eventually:
pip install reip

More detailed installation instruction for NVIDIA Jeton platform can be found here.

Usage

Chain Interface

Javascript-esque method chaining.

import reip
import reip.blocks as B
import reip.blocks.audio

# record audio and buffer into chunks of 10
audio = B.audio.Mic(block_duration=1)
audio10s = (
    audio.to(B.Debug('Audio'))
    .to(B.Rebuffer(duration=10)))
# plot a spectrogram
spec_img = (
    audio10s.to(B.audio.Stft())
    .to(B.Debug('Spec'))
    .to(B.Specshow('plots/{time}.png')))
# to wavefile
wav = (
    audio10s.to(B.Debug('Audio 222'))
    .to(B.audio.AudioFile('audio/{time}.wav')))

print(reip.default_graph())
reip.run()

Function Interface

Mimicking a Keras interface.

import reip.blocks as B

# record audio and buffer into chunks of 10
audio = B.audio.Mic(block_duration=1)
audio10s = B.Rebuffer(duration=10)(audio)

# to spectrogram
stft = B.audio.Stft()(audio)
specshow = B.Specshow('plots/{time}.png')(spec)
# to wavefile
wav10s = B.audio.AudioFile('audio/{time}.wav')(audio10s)

print(reip.default_graph())
reip.run()