如何在AWS Cognito用户注册后将其存储到MongoDB数据库？

最优方案：Lambda直接连接MongoDB（无需额外API端点） #

你的初始思路多了一层API转发，其实Lambda可以直接对接MongoDB，减少系统复杂度和开销，具体步骤如下：

1. 前置准备

• MongoDB访问配置：如果用MongoDB Atlas，需在IP白名单中添加Lambda的公网IP（或配置VPC peering）；如果是自建MongoDB，要确保安全组开放27017端口，且Lambda能访问该网络。
• Lambda权限配置：
  • 给Lambda执行角色添加AmazonCognitoPowerUser权限（或自定义权限，允许Cognito触发器调用）。
  • 若MongoDB在VPC内，需将Lambda部署到同一VPC，并配置对应安全组权限。
• 环境变量配置：在Lambda中设置以下环境变量（避免硬编码敏感信息）：
  • MONGODB_URI：MongoDB连接字符串（如mongodb+srv://user:pass@cluster0.mongodb.net/）
  • DB_NAME：目标数据库名称
  • COLLECTION_NAME：目标集合名称

2. 编写Post Confirmation Lambda函数（Node.js）

用MongoDB官方驱动实现数据同步，注意复用连接提升性能，代码示例：

const { MongoClient } = require('mongodb');

// 环境变量读取
const MONGODB_URI = process.env.MONGODB_URI;
const DB_NAME = process.env.DB_NAME;
const COLLECTION_NAME = process.env.COLLECTION_NAME;

let mongoClient;

// 复用MongoDB连接，避免每次调用重建连接
async function getMongoCollection() {
  if (!mongoClient) {
    mongoClient = new MongoClient(MONGODB_URI);
    await mongoClient.connect();
  }
  return mongoClient.db(DB_NAME).collection(COLLECTION_NAME);
}

exports.handler = async (event) => {
  try {
    // 从Cognito事件中提取用户核心信息
    const userRecord = {
      userId: event.request.userAttributes.sub, // Cognito用户唯一ID
      username: event.userName,
      email: event.request.userAttributes.email,
      emailVerified: event.request.userAttributes.email_verified === 'true',
      createdAt: new Date().toISOString(),
      // 可按需添加其他属性，比如phone_number、name等
    };

    const collection = await getMongoCollection();
    // 用upsert确保重复触发时不会插入重复数据
    await collection.updateOne(
      { userId: userRecord.userId },
      { $set: userRecord },
      { upsert: true }
    );

    console.log(`用户${userRecord.username}数据已同步到MongoDB`);
    return event; // 必须返回event，否则Cognito会判定触发器失败
  } catch (err) {
    console.error('同步失败:', err);
    throw err; // 抛出错误会触发Cognito的重试机制（根据配置）
  }
};

3. 配置Cognito触发器

• 进入AWS Cognito用户池控制台，切换到触发器标签页。
• 在Post Confirmation事件下拉框中选择你刚才创建的Lambda函数，保存配置。

备选方案：通过API端点转发（你的初始思路） #

如果业务需要必须通过API中转，可按以下步骤实现：

1. 创建API Gateway端点：
   • 新建REST API，添加POST方法，后端绑定一个用于写入MongoDB的Lambda函数（或直接对接Express服务）。
2. 修改Post Confirmation Lambda：
   • 在Lambda中用axios或fetch调用API端点，发送Cognito事件中的用户数据。
   • 示例代码片段：

     const axios = require('axios');
     exports.handler = async (event) => {
       try {
         const userData = {
           userId: event.request.userAttributes.sub,
           username: event.userName,
           email: event.request.userAttributes.email
         };
         await axios.post(process.env.API_ENDPOINT, userData);
         return event;
       } catch (err) {
         console.error('调用API失败:', err);
         throw err;
       }
     };
     

3. 权限配置：确保Post Confirmation Lambda有调用API Gateway的权限，API Gateway后端Lambda有访问MongoDB的权限。

关键注意事项 #

• 幂等性：必须用upsert或其他方式确保重复触发时不会产生重复数据（Cognito可能会重试触发器）。
• 敏感信息存储：MongoDB连接字符串等敏感信息建议用AWS Secrets Manager存储，而非直接存在环境变量。
• 超时配置：Lambda超时时间需设置足够（比如10秒），确保能完成MongoDB连接和数据写入。

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