无需中间件即可将DocumentDB与SNS主题连接

要将DocumentDB与SNS主题连接，可以使用AWS Lambda函数。Lambda函数可以直接访问DocumentDB并发布消息到SNS主题，无需使用中间件。

以下是一个使用Node.js的Lambda函数示例代码：

const AWS = require('aws-sdk');
const DocumentClient = new AWS.DynamoDB.DocumentClient();
const SNS = new AWS.SNS();

exports.handler = async (event) => {
    try {
        // 从DocumentDB获取数据
        const params = {
            TableName: 'your-dynamodb-table-name',
            Key: {
                id: 'your-document-id'
            }
        };
        const data = await DocumentClient.get(params).promise();
        const documentData = data.Item;

        // 发布消息到SNS主题
        const snsParams = {
            Message: JSON.stringify(documentData),
            TopicArn: 'your-sns-topic-arn'
        };
        await SNS.publish(snsParams).promise();

        return {
            statusCode: 200,
            body: 'Message published to SNS topic successfully'
        };
    } catch (error) {
        return {
            statusCode: 500,
            body: 'Error publishing message to SNS topic: ' + error.message
        };
    }
};

在代码中，首先创建了一个DocumentClient对象和一个SNS对象，分别用于访问DocumentDB和发布消息到SNS主题。

然后，在Lambda函数的处理程序中，通过调用DocumentClient.get方法从DocumentDB中获取数据。根据需要，可以根据具体的查询条件来获取数据。

接下来，使用SNS.publish方法将获取到的数据发布到指定的SNS主题。在snsParams对象中，Message属性存储要发布的消息内容，TopicArn属性存储SNS主题的ARN。

最后，返回一个包含状态码和响应消息的对象，指示消息是否成功发布到SNS主题。

请注意，上述代码中需要替换的部分有：

• your-dynamodb-table-name：替换为实际的DynamoDB表名。
• your-document-id：替换为实际的Document的ID。
• your-sns-topic-arn：替换为实际的SNS主题ARN。

此外，还需要在Lambda函数的执行角色上授予相应的权限，以便访问DocumentDB和发布消息到SNS主题。

以上是一个使用AWS Lambda函数直接将DocumentDB与SNS主题连接的解决方法，无需中间件。