node.js - 종류 - nodejs 한글




node.js에서 redis로 파이프하는 방법은 무엇입니까? (2)

node_redis에는 모든 명령이 파이프 라인되어 있습니다.

https://github.com/mranney/node_redis/issues/539#issuecomment-32203325

DB의 redis에 (SET \ INCR) 삽입 할 데이터가 많이 있으므로 node.js를 통해 pipeline \ mass 삽입 을 찾고 있습니다.

node.js에서 이렇게 좋은 예제 / API를 찾을 수 없으므로 도움이 될 것입니다.


그렇습니다. 예제가 부족하다는 것에 동의해야합니다.하지만 몇 가지 삽입 명령을 일괄 전송 한 스트림을 만들었습니다.

redis stream 용 모듈을 설치해야합니다.

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-stream 노드 모듈 에서 node.js의 redis stream 을 사용하는 몇 가지 예가 있습니다.





node-redis