如何在Lambda函数中使用AWS SAM生成的动态SQS路径？

方法1：通过SAM模板将SQS路径注入Lambda环境变量 #

在SAM模板里直接把SQS资源的引用作为Lambda的环境变量，堆栈创建完成后，Lambda就能直接读取到动态生成的路径。示例模板代码：

Resources:
  MyQueue:
    Type: AWS::SQS::Queue
    Properties:
      QueueName: MyDynamicQueue

  MyLambdaFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: ./src/
      Handler: app.lambda_handler
      Runtime: python3.11
      Environment:
        Variables:
          SQS_QUEUE_URL: !Ref MyQueue  # 直接引用SQS资源获取URL
          SQS_QUEUE_ARN: !GetAtt MyQueue.Arn  # 需要ARN时可这样获取

Lambda代码中读取环境变量即可使用：

import os
import boto3

sqs = boto3.client('sqs')
queue_url = os.environ['SQS_QUEUE_URL']

def lambda_handler(event, context):
    sqs.send_message(QueueUrl=queue_url, MessageBody="test message")

方法2：将SQS路径设为堆栈输出值 #

如果需要在堆栈创建后手动获取或供其他系统调用，可在模板中添加Outputs部分：

Outputs:
  MyQueueUrl:
    Description: URL of the SQS Queue
    Value: !Ref MyQueue
    Export:
      Name: MyQueueUrl  # 支持跨堆栈引用该输出

创建堆栈后，可通过以下方式获取值：

• AWS CLI命令：aws cloudformation describe-stacks --stack-name YourStackName --query 'Stacks[0].Outputs[?OutputKey==MyQueueUrl].OutputValue' --output text

方法3：运行时通过队列名称查询路径 #

若知晓SQS的名称（比如模板中用!Sub生成带堆栈名的队列名），可在代码中通过名称查询URL：

import boto3

sqs = boto3.client('sqs')
queue_name = "MyDynamicQueue-YourStackName"  # 替换为实际队列名称
response = sqs.get_queue_url(QueueName=queue_name)
queue_url = response['QueueUrl']

若队列在其他账户或区域，需额外传入QueueOwnerAWSAccountId或Region参数。

方法4：跨堆栈引用SQS路径 #

如果SQS在另一个SAM堆栈中创建，当前堆栈可通过!ImportValue导入其输出：

Resources:
  MyLambdaFunction:
    Type: AWS::Serverless::Function
    Properties:
      Environment:
        Variables:
          SQS_QUEUE_URL: !ImportValue MyQueueUrl  # 导入其他堆栈的输出值

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