diff --git a/consumer.go b/consumer.go index d12bce5..3ade377 100644 --- a/consumer.go +++ b/consumer.go @@ -59,9 +59,9 @@ func consumer() { log.Printf("Date Error: %+v - %s - %s\n", err, prod.user, login) 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") ml := MongoLogin{ - // genera l' _ID con user e timestamp ID: mlID, User: prod.user, Protocol: sval[0], diff --git a/dbs.go b/dbs.go index d6bdf98..ebaf976 100644 --- a/dbs.go +++ b/dbs.go @@ -2,7 +2,7 @@ package main import ( - // "fmt" + "fmt" "log" "os" "strings" @@ -92,7 +92,7 @@ func (db *Dbs) connectMongo() { mongoList := strings.Split(db.MongoURI, ",") for m := range mongoList { - nm, err := mgo.Dial(mongoList[m]) + nm, err := mgo.Dial(fmt.Sprintf("mongodb://%s", mongoList[m])) if err != nil { log.Println("Mongodb connect Error: ", err.Error()) os.Exit(-3)