sql >> Base de Datos >  >> NoSQL >> Redis

¿Cómo canalizar en node.js a redis?

Sí, debo estar de acuerdo en que faltan ejemplos para eso, pero logré crear la secuencia en la que envié varios comandos de inserción por lotes.

Debe instalar el módulo para el flujo de redis:

npm install redis-stream

Y así es como usas la transmisión:

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();

Además, puede crear tantos flujos como desee. como quieras y abrirlos/cerrarlos como quieras en cualquier momento.

Hay varios ejemplos de usar redis stream en node.js en el módulo de nodo redis-stream