node-red-node-mongodb

// This quickstart demonstrates direct MongoDB interaction // using the 'mongodb' driver, which is what the Node-RED node // 'node-red-node-mongodb' ultimately uses under the hood. // The Node-RED node provides a visual, flow-based interface // to these operations. // // To use the Node-RED node: // 1. Ensure Node.js and npm are installed. // 2. Install Node-RED globally: npm install -g node-red // 3. Start Node-RED: node-red // 4. Navigate to the Node-RED user directory (typically ~/.node-red). // 5. Install the MongoDB node: npm install node-red-node-mongodb // 6. Restart Node-RED and find the MongoDB nodes in the palette to build flows. import { MongoClient } from 'mongodb'; async function runMongoExample() { // For actual Node-RED use, connection string would be in node config. const uri = process.env.MONGO_URI ?? 'mongodb://localhost:27017'; const dbName = 'nodeRedExampleDB'; const collectionName = 'sensorData'; const client = new MongoClient(uri); try { await client.connect(); console.log("Connected successfully to MongoDB server"); const db = client.db(dbName); const collection = db.collection(collectionName); const dataToInsert = { timestamp: new Date(), temperature: Math.random() * 30 + 15, // Random temp between 15-45 humidity: Math.random() * 40 + 50, // Random humidity between 50-90 location: 'serverRoom01', _id: `sensor_${Date.now()}` // Example for handling _id }; // Insert a document (equivalent to Node-RED 'out' node with 'Insert' operator) const insertResult = await collection.insertOne(dataToInsert); console.log(`Document inserted with _id: ${insertResult.insertedId}`); // Find documents (equivalent to Node-RED 'in' node with 'Find' operator) const query = { location: 'serverRoom01' }; const foundDocuments = await collection.find(query).limit(5).toArray(); console.log(`Found ${foundDocuments.length} documents:`); foundDocuments.forEach(doc => console.log(doc)); // Update a document (equivalent to Node-RED 'out' node with 'Update' operator) const updateResult = await collection.updateOne( { _id: dataToInsert._id }, { $set: { temperature: 25.5, status: 'updated' } } ); console.log(`Matched ${updateResult.matchedCount} docs, modified ${updateResult.modifiedCount} docs.`); } catch (err) { console.error("Failed to connect or perform MongoDB operations:", err); } finally { await client.close(); console.log("MongoDB connection closed."); } } runMongoExample();