pescador_example.py

#!/usr/bin/env python

import numpy as np
import pescador

def data_sampler(filename, n_samples):

    # Load all the data from the file, somehow
    data = load_data(filename)

    for n in range(n_samples):

        x, y = sample(data)
        yield dict(x=x, y=y)



stream = pescador.Streamer(data_sampler, n_samples=128)

streamer = pescador.zmq_stream(stream)

for sample in steamer:
    process(sample)

e.g. sample: pick up the data for this batch x=audio file, y=label, and process= librosa.stft?