如何将node.js管道传输到redis?

2024-05-04

我有很多数据要插入(SET \ INCR)到redis DB,所以我正在寻找pipeline http://redis.io/topics/pipelining \ 质量插入 http://redis.io/topics/mass-insert通过node.js.

我在 Node.js 中找不到任何好的示例/API 来执行此操作,因此任何帮助都会很棒!


是的,我必须同意,缺乏这方面的示例,但我设法创建了一个流,在该流上批量发送了多个插入命令。

您应该安装 redis 流模块:

npm install redis-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();

此外,您还可以创建为许多溪流根据您的需要随时打开/关闭它们。

几个例子使用的Redis流在 Node.js 上redis-stream节点模块 https://github.com/tblobaum/redis-stream/tree/master/example

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何将node.js管道传输到redis? 的相关文章

随机推荐