每次有新的对象插入到mongodb时，我如何检查或流式传输？

要在MongoDB中检查或流式传输每次插入新对象，你可以使用MongoDB的Change Streams功能。Change Streams允许你监听集合中的变化，并在有新的文档插入时触发事件。

下面是一个使用Node.js和MongoDB驱动程序来检查或流式传输新对象插入的示例代码：

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

async function watchInserts() {
  const uri = 'mongodb://localhost:27017';
  const client = new MongoClient(uri);

  try {
    await client.connect();

    const database = client.db('your-database');
    const collection = database.collection('your-collection');

    const changeStream = collection.watch();

    changeStream.on('change', (change) => {
      if (change.operationType === 'insert') {
        const newObject = change.fullDocument;
        console.log('New object inserted:', newObject);
        // 这里可以执行你想要的操作，如发送到消息队列、进行数据处理等
      }
    });

    // 监听变化
    await changeStream.hasNext();
  } catch (error) {
    console.error('Error:', error);
  } finally {
    await client.close();
  }
}

watchInserts();

上面的代码首先创建了一个MongoDB客户端实例，并连接到本地的MongoDB服务器。然后，它选择了一个数据库和一个集合，并创建了一个Change Stream来监听该集合的变化。

在changeStream.on('change')的回调函数中，我们检查操作类型是否为insert，如果是，我们就可以获取到新插入的文档对象newObject，并执行你想要的操作。

最后，我们通过changeStream.hasNext()来持续监听变化，直到程序退出或手动关闭连接。

请注意，为了使用Change Streams功能，你需要MongoDB版本3.6或更高版本，并且必须启用复制集。