对多个MongoDB集合的抓取写入

const mongoose = require('mongoose');

// 连接MongoDB数据库
mongoose.connect('mongodb://localhost/mydatabase', { useNewUrlParser: true, useUnifiedTopology: true });

// 定义集合的数据模型
const UserSchema = new mongoose.Schema({
  name: String,
  age: Number
});

const PostSchema = new mongoose.Schema({
  title: String,
  content: String
});

// 创建集合模型
const User = mongoose.model('User', UserSchema);
const Post = mongoose.model('Post', PostSchema);

// 抓取数据并写入多个集合
async function fetchDataAndWrite() {
  try {
    // 抓取数据
    const userData = await fetchUserData();
    const postData = await fetchPostData();

    // 写入User集合
    await User.insertMany(userData);

    // 写入Post集合
    await Post.insertMany(postData);

    console.log('数据写入成功！');
  } catch (error) {
    console.error('数据写入失败：', error);
  }
}

// 模拟抓取用户数据
function fetchUserData() {
  return new Promise((resolve, reject) => {
    // 模拟异步请求
    setTimeout(() => {
      const userData = [
        { name: 'Alice', age: 25 },
        { name: 'Bob', age: 30 }
      ];
      resolve(userData);
    }, 1000);
  });
}

// 模拟抓取文章数据
function fetchPostData() {
  return new Promise((resolve, reject) => {
    // 模拟异步请求
    setTimeout(() => {
      const postData = [
        { title: 'Post 1', content: 'Content 1' },
        { title: 'Post 2', content: 'Content 2' }
      ];
      resolve(postData);
    }, 1000);
  });
}

// 执行抓取写入操作
fetchDataAndWrite();