Hoe pijplijn in node.js naar redis?

Ja, ik ben het ermee eens dat daar geen voorbeelden voor zijn, maar het is me gelukt om de stream te maken waarop ik verschillende invoegopdrachten in batch heb verzonden.

Je moet de module voor redis stream installeren:

npm install redis-stream

En zo gebruik je de stream:

var redis = require('redis-stream'),
    client = new redis(6379, '127.0.0.1');

// Open stream
var stream = client.stream();

// Example of setting 10000 records
for(var record = 0; record < 10000; record++) {

    // Command is an array of arguments:
    var command = ['set', 'key' + record, 'value'];  

    // Send command to stream, but parse it before
    stream.redis.write( redis.parse(command) );
}

// Create event when stream is closed
stream.on('close', function () {
    console.log('Completed!');

    // Here you can create stream for reading results or similar
});

// Close the stream after batch insert
stream.end();

U kunt ook zo veel streams . maken zoals u wilt en open/sluit ze wanneer u maar wilt.

Er zijn verschillende voorbeelden van het gebruik van redis stream in node.js op redis-stream node-module