是的,我必须同意缺少示例,但是我设法创建了一个流,在该流上我批量发送了几个插入命令。
您应该为redis流安装模块:
npm install redis-stream
这就是您使用流的方式:
var redis = require('redis-stream'), client = new redis(6379, '127.0.0.1');// Open streamvar stream = client.stream();// Example of setting 10000 recordsfor(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 closedstream.on('close', function () { console.log('Completed!'); // Here you can create stream for reading results or similar});// Close the stream after batch insertstream.end();
另外,您可以根据需要创建任意数量的 流 ,并可以随时打开/关闭它们。
在redis-stream节点模块上的node.js中有 几个 使用 Redis流的
示例
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)