|
@ -387,11 +387,12 @@ function onCollection(err, collection) { |
|
|
// db.collection('log', onCollection);
|
|
|
// db.collection('log', onCollection);
|
|
|
//}
|
|
|
//}
|
|
|
|
|
|
|
|
|
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/?replicaSet=rs1" |
|
|
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" |
|
|
//MongoClient.connect(mongourl, options).then((client) => {
|
|
|
//MongoClient.connect(mongourl, options).then((client) => {
|
|
|
MongoClient.connect(mongourl).then((client) => { |
|
|
MongoClient.connect(mongourl).then((client) => { |
|
|
const db = client.db('fluent'); |
|
|
//const db = client.db('fluent');
|
|
|
db.collection('log', onCollection); |
|
|
//db.collection('log', onCollection);
|
|
|
|
|
|
client.collection('log', onCollection); |
|
|
// do database things
|
|
|
// do database things
|
|
|
}).catch((error) => { |
|
|
}).catch((error) => { |
|
|
console.log("connect_error_mongo " +JSON.stringify(error)) |
|
|
console.log("connect_error_mongo " +JSON.stringify(error)) |
|
|