保存在mongodb中，并将创建的对象传递给函数

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

// MongoDB 连接字符串
const uri = 'mongodb://localhost:27017';
const client = new MongoClient(uri, { useNewUrlParser: true, useUnifiedTopology: true });

async function main() {
  try {
    // 连接到 MongoDB
    await client.connect();
    console.log('Connected to MongoDB');

    // 选择数据库和集合
    const database = client.db('myDatabase');
    const collection = database.collection('myCollection');

    // 创建一个文档
    const myDocument = {
      name: 'John Doe',
      age: 30,
      email: 'john.doe@example.com'
    };

    // 插入文档到集合
    const insertResult = await collection.insertOne(myDocument);
    console.log('Document inserted:', insertResult.insertedId);

    // 将创建的对象传递给函数
    processDocument(myDocument);
  } catch (err) {
    console.error(err);
  } finally {
    // 关闭连接
    await client.close();
    console.log('Disconnected from MongoDB');
  }
}

function processDocument(document) {
  console.log('Processing document:', document);
  // 在这里进行进一步的处理
}

// 执行主函数
main().catch(console.error);

// 创建唯一索引
await collection.createIndex({ email: 1 }, { unique: true });

# 检查 MongoDB 服务状态
sudo systemctl status mongod