通過javascript向ElasticSearch索引添加文檔循環不起作用

Question

我從PostgreSQL數據庫中檢索了很多行（存儲在result.rows中），並且我想將它們添加到我的ElasticSearch索引中。

只添加一個文件工作正常：

var r = result.rows[0]; 
esClient.index({ 
    index: 'families', 
    type: 'families', 
    id: r.family_accession, 
    body: { 
     'family_accession' : r.family_accession, 
     'count_seq'   : r.count_seq, 
     'count_taxon'  : r.count_taxon 
    } 
}, function (error, response) { 
    console.log(error); 
}); 

但是當我嘗試把它叫成一個圈，它不會在所有的工作：既然你調用一個異步

result.rows.forEach(function (r) { 
    esClient.index({ 
    index: 'families', 
    type: 'families', 
    id: r.family_accession, 
    body: { 
     'family_accession' : r.family_accession, 
     'count_seq'   : r.count_seq, 
     'count_taxon'  : r.count_taxon 
    } 
    }, function (error, response) { 
    console.log(error); 
    }); 
}); 

Answer 1

一段代碼在一個循環中，調用esClient.index()函數時出現的上下文在執行回調的時候不再存在。

您需要將它放在閉包中以保持執行環境。

result.rows.forEach(function (r) { 
    (function(row) { 
    esClient.index({ 
     index: 'families', 
     type: 'families', 
     id: row.family_accession, 
     body: { 
      'family_accession' : row.family_accession, 
      'count_seq'   : row.count_seq, 
      'count_taxon'  : row.count_taxon 
     } 
    }, function (error, response) { 
     console.log(error); 
    }); 
    })(r); 
});