Có, tôi phải đồng ý rằng thiếu ví dụ cho điều đó nhưng tôi đã quản lý để tạo luồng mà tôi đã gửi một số lệnh chèn hàng loạt.
Bạn nên cài đặt mô-đun cho luồng redis:
npm install redis-stream
Và đây là cách bạn sử dụng luồng:
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();
Ngoài ra, bạn có thể tạo dưới dạng nhiều luồng như bạn muốn và mở / đóng chúng bất cứ lúc nào bạn muốn.
Có một số ví dụ sử dụng redis stream trong node.js trên mô-đun nút redis-stream