Reduced Bulk response size to improve performance

shubhisood · Aug 18, 2020 · 6efcc94 · 6efcc94
1 parent d367303
commit 6efcc94
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/reindexAuditLogs.js b/reindexAuditLogs.js
@@ -10,6 +10,7 @@ async function callBulkAPI(elindex) {
     const bulkResponse = await elasticClient.bulk({
       body: elindex,
       timeout: '5m',
+      filterPath:'items.index._id,errors'
     });
     if(bulkResponse.errors) {
       throw new Error(JSON.stringify(bulkResponse));

diff --git a/reindexLogstashLogs.js b/reindexLogstashLogs.js
@@ -10,6 +10,7 @@ async function callBulkAPI(elindex) {
     const bulkResponse = await elasticClient.bulk({
       body: elindex,
       timeout: '5m',
+      filterPath:'items.index._id,errors'
     });
     if(bulkResponse.errors) {
       console.error('ERROR RESPONSE_____________________________');

diff --git a/reindexRidesData.js b/reindexRidesData.js
@@ -9,6 +9,7 @@ async function callBulkAPI(elindex) {
     const bulkResponse = await elasticClient.bulk({
       body: elindex,
       timeout: '5m',
+      filterPath:'items.index._id,errors'
     });
     if(bulkResponse.errors) {
      throw new Error(JSON.stringify(bulkResponse))