Skip to content

Commit b159fb5

Browse files
committed
fix: metadata index script
It should explicitly set doc id to the same which is used by "project-processor-es"
1 parent 51b2daf commit b159fb5

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

config/custom-environment-variables.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,8 @@
1414
"timelineIndexName": "TIMELINES_ES_INDEX_NAME",
1515
"timelineDocType": "TIMELINES_ES_DOC_TYPE",
1616
"metadataIndexName": "METADATA_ES_INDEX_NAME",
17-
"metadataDocType": "METADATA_ES_DOC_TYPE"
17+
"metadataDocType": "METADATA_ES_DOC_TYPE",
18+
"metadataDocDefaultId": "METADATA_ES_DOC_DEFAULT_ID"
1819
},
1920
"rabbitmqURL": "RABBITMQ_URL",
2021
"pubsubQueueName": "PUBSUB_QUEUE_NAME",

config/default.json

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,8 @@
2525
"timelineIndexName": "timelines",
2626
"timelineDocType": "doc",
2727
"metadataIndexName": "metadata",
28-
"metadataDocType": "doc"
28+
"metadataDocType": "doc",
29+
"metadataDocDefaultId": 1
2930
},
3031
"connectProjectUrl":"",
3132
"dbConfig": {

src/utils/es.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import { MAPPINGS } from './es-config';
99

1010
const ES_METADATA_INDEX = config.get('elasticsearchConfig.metadataIndexName');
1111
const ES_METADATA_TYPE = config.get('elasticsearchConfig.metadataDocType');
12+
const ES_METADATA_DEFAULT_ID = config.get('elasticsearchConfig.metadataDocDefaultId');
1213

1314
const eClient = util.getElasticSearchClient();
1415

@@ -52,7 +53,9 @@ const modelConfigs = {
5253
*/
5354
async function indexMetadata() {
5455
const modelNames = _.keys(modelConfigs);
55-
const body = {};
56+
const body = {
57+
id: ES_METADATA_DEFAULT_ID,
58+
};
5659

5760
for (let i = 0; i < modelNames.length; i += 1) {
5861
const modelName = modelNames[i];
@@ -67,6 +70,7 @@ async function indexMetadata() {
6770
return eClient.index({
6871
index: ES_METADATA_INDEX,
6972
type: ES_METADATA_TYPE,
73+
id: ES_METADATA_DEFAULT_ID,
7074
body,
7175
refresh: 'wait_for',
7276
});

0 commit comments

Comments
 (0)