Browse Source

mongo tail

master
zeus 4 years ago
parent
commit
0a0fae825e
  1. 31
      swarmlab-app/src/run/app.js

31
swarmlab-app/src/run/app.js

@ -253,6 +253,37 @@ app.get('/run', [
cors(corsOptions), (req, res, next) => { cors(corsOptions), (req, res, next) => {
(async() => { (async() => {
var mongourl = "mongodb://playgrounduser:efvvnuioervefSDFSGYGHRDFVsdfergvssppiiedifhwincvinviw_dbfjbsifbsdkjfswuunscfudfgbbfvibqefwrvnine@ondemand_playground_mongo1:27017,ondemand_playground_mongo2:27017,ondemand_playground_mongo3:27017,ondemand_playground_mongo4:27017,ondemand_playground_mongo5:27017,ondemand_playground_mongo6:27017,ondemand_playground_mongo7:27017/fluent?replicaSet=rs1"
const OPTS = {
useNewUrlParser: true,
useUnifiedTopology: true
};
MongoClient.connect(mongourl, OPTS, function(err, client){
if(err){
console.log(err);
} else {
const db = client.db('fluent');
//db.collection('log', onCollection);
var stream = db.collection('log').find({}, {
tailable: true,
awaitdata: true
/* other options */
}).stream();
stream.on('data', function (doc) {
console.log(JSON.stringify(doc))
//socket.write(JSON.stringify({'action': 'log','param': doc.log}));
});
/*
db.collection(function(err, collections) {
collections.forEach(function(coll) {
console.log(coll.s.name);
});
});
*/
}
});
var RES = new Object(); var RES = new Object();
RES.code = req.query["filter"] RES.code = req.query["filter"]
RES.token = req.query["filter"] RES.token = req.query["filter"]

Loading…
Cancel
Save