Merge 90ddb6f into 7d432a3

robertstettner · Oct 11, 2016 · fd7bdd2 · fd7bdd2
2 parents 7d432a3 + 90ddb6f
commit fd7bdd2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/elasticsearch_csv.js b/lib/elasticsearch_csv.js
@@ -43,7 +43,7 @@ elasticsearch_csv.prototype = {
                 csvStream = csv(_.omit(this.options.csv, ['filePath']))
                     .on('data', (function (data) {
                         if (_.isPlainObject(data)) {
-                            request.body.push({ index: { _index: this.options.es.index, _type: this.options.es.type, _id: uuid.v4() } });
+                            request.body.push({ index: { _index: this.options.es.index, _type: this.options.es.type, _id: data('_id') || uuid.v4() } });
                             _.forEach(data, function (value, key) {
                                 try {
                                     data[key] = JSON.parse(value);
@@ -77,4 +77,4 @@ elasticsearch_csv.prototype = {
     }
 };
 
-module.exports = elasticsearch_csv;
+module.exports = elasticsearch_csv;