Function awsRequest

packages/serverless/lib/aws/v2/request.js:129–245

Execute request to AWS service * @param {Object|string} [service] - Description of the service to call * @prop [service.name] - Name of the service to call, support subclasses * @prop [service.params] - Parameters to apply when creating the service and doing the request * @prop [service.params.c

(service, method, ...args)

 * @param {Array} args - Argument for the method call
 */
async function awsRequest(service, method, ...args) {
  // Checks regarding expectations on service object
  if (isObject(service)) {
    ensureString(service.name, { name: 'service.name' })
  } else {
    ensureString(service, { name: 'service' })
    service = { name: service }
  }
  const BASE_BACKOFF = 5000
  const persistentRequest = async (f, numTry = 0) => {
    try {
      return await f()
    } catch (e) {
      const { providerError } = e
      if (
        numTry < MAX_RETRIES &&
        providerError &&
        ((providerError.retryable &&
          providerError.statusCode !== 403 &&
          providerError.code !== 'CredentialsError' &&
          providerError.code !== 'ExpiredTokenException') ||
          providerError.statusCode === 429)
      ) {
        const nextTryNum = numTry + 1
        const jitter = Math.random() * 3000 - 1000
        // backoff is between 4 and 7 seconds
        const backOff = BASE_BACKOFF + jitter
        log.info(
          [
            `Recoverable error occurred (${
              e.message
            }), sleeping for ~${Math.round(backOff / 1000)} seconds.`,
            `Try ${nextTryNum} of ${MAX_RETRIES}`,
          ].join(' '),
        )
        await wait(backOff)
        return persistentRequest(f, nextTryNum)
      }
      throw e
    }
  }
  const request = await requestQueue.add(() =>
    persistentRequest(async () => {
      const requestId = ++requestCounter
      const awsService = getServiceInstance(service, method)
      awsLog.debug(`request: #${requestId} ${service.name}.${method}`, args)
      const req = awsService[method](...args)
      try {
        const result = await req.promise()
        awsLog.debug(
          `request result: #${requestId} ${service.name}.${method}`,
          result,
        )
        return result
      } catch (err) {
        awsLog.debug(
          `request error: #${requestId} - ${service.name}.${method}`,
          err,