in code/log-processing/src/handlers/index.js [231:246]
minTimeout: parseFloat(process.env.RETRY_MIN_TIMEOUT || '1000'),
maxTimeout: parseFloat(process.env.RETRY_MAX_TIMEOUT || '60000'),
factor: 2,
onRetry: (err) => log.warn('retrying publishing CloudWatch metrics...', err)
})
.then(() => log.debug(`sent [${chunk.length}] metrics`))
.catch(err => log.error(
`failed to publish [${chunk.length}] metrics, skipped...`,
{ request: req },
err))
}
}
const processAll = async (cwLogEvents) => {
const metrics = _.flatMap(cwLogEvents, logEvent => {
if (logEvent.isRaw) {