MongoDB/llmongodb
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

modificato parametro nome DB (mongo)

Browse source
This commit is contained in:
Michele 2017-02-13 10:32:43 +01:00
parent 58518c4b6a
commit 50b09f7050
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
consumer.go
View file

@ -59,9 +59,9 @@ func consumer() {
log.Printf("Date Error: %+v - %s - %s\n", err, prod.user, login) log.Printf("Date Error: %+v - %s - %s\n", err, prod.user, login)
continue continue
} }
// genera l' _ID con user + timestamp + ip
mlID := hash([]byte(fmt.Sprintf("%s%s%s", prod.user, time.Unix(date, 0).Format("20060102T15"), sval[2]))) // Format("20060102T150405") mlID := hash([]byte(fmt.Sprintf("%s%s%s", prod.user, time.Unix(date, 0).Format("20060102T15"), sval[2]))) // Format("20060102T150405")
ml := MongoLogin{ ml := MongoLogin{
// genera l' _ID con user e timestamp
ID: mlID, ID: mlID,
User: prod.user, User: prod.user,
Protocol: sval[0], Protocol: sval[0],

4
dbs.go
View file

@ -2,7 +2,7 @@
package main package main
import ( import (
// "fmt" "fmt"
"log" "log"
"os" "os"
"strings" "strings"
@ -92,7 +92,7 @@ func (db *Dbs) connectMongo() {
mongoList := strings.Split(db.MongoURI, ",") mongoList := strings.Split(db.MongoURI, ",")
for m := range mongoList { for m := range mongoList {
nm, err := mgo.Dial(mongoList[m]) nm, err := mgo.Dial(fmt.Sprintf("mongodb://%s", mongoList[m]))
if err != nil { if err != nil {
log.Println("Mongodb connect Error: ", err.Error()) log.Println("Mongodb connect Error: ", err.Error())
os.Exit(-3) os.Exit(-3)