vw-stream

Online machine learning with Vowpal Wabbit as Node.js streams.

Features

• Stream Abstraction: Treat a Vowpal Wabbit learner process as a writable & readable stream. You write training or testing examples, and read predictions from the stream.
• Sparse Example Format: Represent your training or testing examples and observations naturally, as sparse JavaScript objects.
• Namespace Mapping: Use descriptive feature namespace names, which are mapped under-the-hood onto Vowpal Wabbit's preferred single-character namespace codes.
• Live Model Persistence: Retrieve the Vowpal Wabbit binary model ("regressor") during training or testing. You never need to shut-down the Vowpal Wabbit process!
• Child, Not Daemon: Uses a spawned child process for Vowpal Wabbit, for simpler interaction and IPC management.

Example

From the Vowpal Wabbit tutorial:

var vw = new VowpalWabbitStream({ learningRate: 10 });
vw.on('data', function(obj) {
    console.log("Prediction & Average Loss:", obj.ex, obj.pred, vw.getAverageLoss());
});
var exs = [
    { resp: 0, featMap: { price: 0.23, sqft: 0.25, age: 0.05, yr2006: 1.0 } },
    { resp: 1, imp: 2.0, featMap: { price: 0.18, sqft: 0.15, age: 0.35, yr1976: 1.0 } },
    { resp: 0, initPred: 0.5, featMap: { price: 0.53, sqft: 0.32, age: 0.87, yr1924: 1.0 } }
];
for (var pass=0; pass < 25; pass++) {
    for (var i=0; i < exs.length; i++) {
        vw.write(exs[i]);
    }
}
vw.end();
/*
[20150604@15:30:24.893] DEBUG -- VW(STDERR): finished run
[20150604@15:30:24.893] DEBUG -- VW(STDERR): number of examples per pass = 75
...
[20150604@15:30:24.894] DEBUG -- VW(STDERR): average loss = 0.057188
*/

Shout-outs

• To driffer85 for his earlier wrapper.