Compare commits
2 Commits
e644475fbc
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| 4cbde45293 | |||
| 559c7d64d6 |
@@ -34,7 +34,6 @@ function handleError(err) {
|
||||
}
|
||||
|
||||
async function fetchAndIndex() {
|
||||
logger.debug('Fetching and indexing data...');
|
||||
return mod(index, { elasticsearch: { ...esConfig, auth }, filter: { lat, lon, radius } });
|
||||
}
|
||||
|
||||
|
||||
@@ -17,7 +17,6 @@ export default async function(indexName, opts = {}) {
|
||||
const index = await createIndex(client, indexName);
|
||||
|
||||
const records = await getAdbsExchangeData(opts.filter);
|
||||
logger.debug(`Record count:, ${records.length}`);
|
||||
|
||||
await bulkInsert(client, index, records);
|
||||
logger.debug(`Successfully indexed ${records.length} records to ${index}`);
|
||||
|
||||
@@ -58,10 +58,8 @@ export async function createIndex(client, index) {
|
||||
})
|
||||
.catch(err => {
|
||||
// check for existing index
|
||||
if (err instanceof BadRequest) {
|
||||
logger.debug(`Index exists: ${realIndex}`);
|
||||
if (err instanceof BadRequest)
|
||||
return client.indices.get({ index: realIndex }).then(() => realIndex);
|
||||
}
|
||||
|
||||
throw err;
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user