LocalStack环境下SQS订阅SNS失败问题求助

核心错误原因 #

使用sqs协议订阅时，必须传入SQS队列的ARN作为Endpoint，而非队列URL或HTTP地址——你当前的CLI命令和SDK代码都误用了错误的Endpoint格式，导致InvalidParameter报错。

分步解决方案 #

1. 获取SQS队列的ARN #

首先通过命令或SDK获取目标队列的ARN：

用awslocal CLI：

awslocal sqs get-queue-attributes \
--queue-url "http://localhost:4566/000000000000/test" \
--attribute-names QueueArn

返回结果中会包含类似arn:aws:sqs:us-east-1:000000000000:test的ARN值。

用AWS SDK（TypeScript）：

import { SQSClient, GetQueueAttributesCommand } from "@aws-sdk/client-sqs";

const sqsClient = new SQSClient({
  endpoint: "http://localhost:4566",
  region: "us-east-1",
});

const queueAttributes = await sqsClient.send(new GetQueueAttributesCommand({
  QueueUrl: testQueueURL,
  AttributeNames: ["QueueArn"],
}));
const queueArn = queueAttributes.Attributes?.QueueArn;

2. 修正SNS订阅操作 #

修正后的awslocal命令：

awslocal sns subscribe \
--protocol sqs \
--topic-arn "arn:aws:sns:us-east-1:000000000000:test" \
--notification-endpoint "arn:aws:sqs:us-east-1:000000000000:test"

注意：--protocol显式指定为sqs，--notification-endpoint填队列ARN。

修正后的AWS SDK代码：

import { SNSClient, SubscribeCommand } from "@aws-sdk/client-sns";

const snsClient = new SNSClient({
  endpoint: "http://localhost:4566",
  region: "us-east-1",
});

const input: SubscribeCommandInput = {
  TopicArn: testTopicArn.TopicArn,
  Protocol: "sqs",
  Endpoint: queueArn, // 使用队列ARN而非URL
  ReturnSubscriptionArn: true,
};

const subscription = await snsClient.send(new SubscribeCommand(input));

3. 配置SQS队列权限 #

必须给SQS队列添加权限策略，允许对应SNS主题发送消息到队列，否则消息会被拒绝：

用awslocal CLI设置权限：

awslocal sqs set-queue-attributes \
--queue-url "http://localhost:4566/000000000000/test" \
--attributes '{
  "Policy": "{\"Version\":\"2012-10-17\",\"Statement\":[{\"Effect\":\"Allow\",\"Principal\":\"*\",\"Action\":\"sqs:SendMessage\",\"Resource\":\"arn:aws:sqs:us-east-1:000000000000:test\",\"Condition\":{\"ArnEquals\":{\"aws:SourceArn\":\"arn:aws:sns:us-east-1:000000000000:test\"}}}]}"
}'

替换其中的Resource和aws:SourceArn为你的队列ARN和主题ARN。

关于HTTP协议订阅的额外说明 #

你用HTTP协议订阅成功后出现404，是因为HTTP协议要求的是可接收POST请求的自定义HTTP服务端点，而非SQS的队列地址。SQS本身不支持作为HTTP订阅的接收端点，因此该方式无法实现消息投递到队列，建议直接使用sqs协议完成订阅。

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