NestJS集成AWS SQS报错：无法从任何提供商加载凭证

使用@ssut/nestjs-sqs包将AWS SQS集成到NestJS应用，接收队列消息时触发以下错误：

/Users/avinash.anshu/Project/Practice/amazon-sqs-nest/node_modules/sqs-consumer/dist/errors.js:40
    const sqsError = new SQSError(message);
                     ^
SQSError: SQS receive message failed: Could not load credentials from any providers
    at toSQSError (/Users/avinash.anshu/Project/Practice/amazon-sqs-nest/node_modules/sqs-consumer/dist/errors.js:40:22)
    at Consumer.receiveMessage (/Users/avinash.anshu/Project/Practice/amazon-sqs-nest/node_modules/sqs-consumer/dist/consumer.js:173:43)
    at processTicksAndRejections (node:internal/process/task_queues:95:5)

环境信息 #

• 框架：NestJS
• 依赖包：已安装@ssut/nestjs-sqs
• 配置：已定义包含AWS区域、队列详情的config对象

代码示例 #

import { Injectable } from '@nestjs/common';
import { SqsMessageHandler } from '@ssut/nestjs-sqs';
import * as AWS from 'aws-sdk';
import { config } from '../config';

console.log('config.AWS_REGION', config);

@Injectable()
export class MessageHandler {
    constructor() { }

    @SqsMessageHandler(config.TEST_QUEUE, false)
    async handleMessage(message: AWS.SQS.Message) {
        const obj: any = JSON.parse(message.Body) as {
            message: string;
            date: string;
        };
        const { data } = JSON.parse(obj.Message);
        console.log(data);

        // use the data and consume it the way you want //
    }
}

解决方案 #

错误核心是AWS SDK无法获取合法的访问凭证，以下是几种可行的配置方式：

1. 开发环境临时硬编码配置（不推荐生产使用） #

在应用初始化时手动配置AWS SDK凭证：

import * as AWS from 'aws-sdk';
import { config } from '../config';

AWS.config.update({
  accessKeyId: '你的AWS_ACCESS_KEY_ID',
  secretAccessKey: '你的AWS_SECRET_ACCESS_KEY',
  region: config.AWS_REGION,
});

2. 环境变量配置 #

在项目根目录创建.env文件，添加凭证信息：

AWS_ACCESS_KEY_ID=你的AWS_ACCESS_KEY_ID
AWS_SECRET_ACCESS_KEY=你的AWS_SECRET_ACCESS_KEY
AWS_REGION=你的AWS区域

通过NestJS的ConfigModule加载环境变量后，AWS SDK会自动读取这些值。

3. 本地AWS凭证文件 #

在用户目录下创建.aws/credentials文件（Windows路径：C:\Users\<用户名>\.aws\credentials）：

[default]
aws_access_key_id = 你的AWS_ACCESS_KEY_ID
aws_secret_access_key = 你的AWS_SECRET_ACCESS_KEY

同时创建.aws/config文件配置区域：

[default]
region = 你的AWS区域

AWS SDK会自动读取本地凭证文件内容。

4. 配置SqsModule参数 #

在导入SqsModule时直接传入凭证和队列配置：

import { Module } from '@nestjs/common';
import { SqsModule } from '@ssut/nestjs-sqs';
import { config } from './config';

@Module({
  imports: [
    SqsModule.register({
      consumers: [
        {
          name: config.TEST_QUEUE,
          queueUrl: '你的SQS队列完整URL',
          region: config.AWS_REGION,
          credentials: {
            accessKeyId: '你的AWS_ACCESS_KEY_ID',
            secretAccessKey: '你的AWS_SECRET_ACCESS_KEY',
          },
        },
      ],
    }),
  ],
  providers: [MessageHandler],
})
export class AppModule {}

5. 生产环境IAM角色（AWS部署场景） #

如果应用部署在EC2、ECS、EKS等AWS服务上，给实例/任务绑定具备SQS访问权限的IAM角色，AWS SDK会自动获取角色凭证，无需手动配置。

内容的提问来源于stack exchange，提问作者Avinash A