MongoDb 实时（或接近实时）流式传输插入的数据

MongoDB 是一个开源的文档数据库，可用于存储和处理大量的非结构化数据。它具有高度的可扩展性和灵活性，能够处理实时或接近实时的流式传输插入的数据。本文将介绍如何使用 MongoDB 实现流式数据处理，并提供一个案例代码来帮助读者更好地理解。

javascript
const { MongoClient } = require("mongodb");
async function watchDatabase() {
  const uri = "mongodb://localhost:27017";
  const client = new MongoClient(uri);
  try {
    await client.connect();
    const database = client.db("mydb");
    const collection = database.collection("mycollection");
    const changeStream = collection.watch();
    changeStream.on("change", (change) => {
      console.log("Received a change:", change);
      // 在这里可以对数据进行相应的处理
    });
    await new Promise((resolve) => setTimeout(resolve, 60000)); // 监听 60 秒
    await changeStream.close();
  } catch (error) {
    console.error("An error occurred:", error);
  } finally {
    await client.close();
  }
}
watchDatabase();