node-elasticsearch-broker
v1.0.4
Published
safety elasticsearch bulk data broker with bucket and job queue
Downloads
1
Maintainers
Readme
node-elasticsearch-broker
safety elasticsearch bulk data broker with bucket and job queue
Usage
Create
var EsBroker = require('node-elasticsearch-broker');
var esBroker = EsBroker.create({
parser: function, //user data parser which will be parsed in job_queue
target: string, //elasticsearch host target
max_bulk_qtty: number, //maximum bulk quantity sent to elasticsearch at once
max_request_num: number, //maximum request number concurrently.
verbose: boolean, //verbose
index: string //elastic_search index
}};
Push
esBroker.push(string);
Close
esBroker.close(callback);