CDK TypeScript中S3新增对象时向SQS发消息报错求助

问题说明 #

需求：当对象上传到S3桶时，向SQS队列发送内容为“hello”的消息。用户尝试的代码中，最后一行queue.send(message)报错，提示“property does not exist on type queue”。

用户错误代码：

import sqs = require('@aws-cdk/aws-sqs');
import s3 = require('@aws-cdk/aws-s3');
import s3n = require('@aws-cdk/aws-s3-notifications');
import { Construct } from '@aws-cdk/core';

export class SendMessageStack extends Construct {

    constructor(scope: Construct, id: string) {
        super(scope, id);

        // Create an S3 bucket 
        const bucket=new s3.Bucket(this, 'bucket') // 原代码缺少闭合括号

        const queue=new sqs.Queue(this, 'queue', {
            visibilityTimeout: cdk.Duration.seconds(300) // 原代码未导入cdk
        });

        // Add an event notification to the bucket to send messages to the queue
        bucket.addEventNotification(s3n.EventType.OBJECT_CREATED, 
                               new s3n.SqsDestination(queue));

        // Create a sqs message with content body “Hello World”
        const message = {
            contentBody: "Hello world",
        };

        // To send a message
        queue.send(message); // 此处报错：queue类无send方法
    }
}

错误原因 #

queue.send()不是AWS CDK中sqs.Queue类的方法。CDK是基础设施即代码工具，仅负责定义、部署AWS资源（比如创建S3桶、SQS队列），不负责在部署阶段直接发送消息。S3到SQS的原生通知会发送固定格式的事件消息（包含对象上传的详情），无法直接自定义为“hello”，需要额外处理。

正确实现方案 #

要实现自定义消息发送，需通过Lambda中间层转换：S3事件触发Lambda，Lambda调用AWS SDK发送自定义“hello”消息到SQS。

修正后的完整代码 #

import * as sqs from '@aws-cdk/aws-sqs';
import * as s3 from '@aws-cdk/aws-s3';
import * as lambda from '@aws-cdk/aws-lambda';
import * as s3n from '@aws-cdk/aws-s3-notifications';
import { Construct, Duration } from '@aws-cdk/core';

export class SendMessageStack extends Construct {
  constructor(scope: Construct, id: string) {
    super(scope, id);

    // 1. 创建S3桶
    const bucket = new s3.Bucket(this, 'MyBucket');

    // 2. 创建SQS队列
    const queue = new sqs.Queue(this, 'MyQueue', {
      visibilityTimeout: Duration.seconds(300),
    });

    // 3. 创建Lambda函数：接收S3事件，发送自定义消息到SQS
    const messageSenderLambda = new lambda.Function(this, 'MessageSenderLambda', {
      runtime: lambda.Runtime.NODEJS_18_X,
      handler: 'index.handler',
      code: lambda.Code.fromInline(`
        const AWS = require('aws-sdk');
        const sqsClient = new AWS.SQS();
        
        exports.handler = async (event) => {
          try {
            await sqsClient.sendMessage({
              QueueUrl: process.env.QUEUE_URL,
              MessageBody: 'hello'
            }).promise();
            return { statusCode: 200, body: 'Message sent successfully' };
          } catch (error) {
            console.error('Error sending message:', error);
            return { statusCode: 500, body: 'Failed to send message' };
          }
        };
      `),
      environment: {
        QUEUE_URL: queue.queueUrl, // 传递队列URL到Lambda环境变量
      },
      timeout: Duration.seconds(10),
    });

    // 4. 给Lambda授予发送SQS消息的权限
    queue.grantSendMessages(messageSenderLambda);

    // 5. 配置S3桶事件：当对象创建时触发Lambda
    bucket.addEventNotification(s3.EventType.OBJECT_CREATED, new s3n.LambdaDestination(messageSenderLambda));
  }
}

关键说明 #

1. 语法修正：修复了原代码中缺少括号、未导入Duration等基础语法错误。
2. Lambda中间层：通过Lambda实现自定义消息逻辑，因为S3原生通知无法修改消息内容。
3. 权限配置：使用queue.grantSendMessages()自动生成IAM权限，允许Lambda发送消息到队列，无需手动编写复杂的IAM策略。
4. 运行时操作：发送消息是运行时行为，必须在Lambda（或其他运行时环境）中调用AWS SDK的sendMessage API，而非在CDK的资源定义代码中执行。

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