|
@@ -61,7 +61,10 @@ func MoveListData() {
|
|
|
logger.Debug("spider_highlistdata删除数据量:", delNum)
|
|
|
|
|
|
logger.Debug("开始迁移spider_listdata数据...")
|
|
|
- //1、spider_listdata数据迁移,只保留一个月
|
|
|
+ //1、spider_listdata数据迁移,只保留两个月
|
|
|
+ query["comeintime"] = map[string]interface{}{
|
|
|
+ "$lt": time.Now().Unix() - 60*86400,
|
|
|
+ }
|
|
|
count, _ = sess.DB(util.MgoS.DbName).C("spider_listdata").Find(&query).Count()
|
|
|
logger.Debug("spider_listdata迁移数据量:", count)
|
|
|
it1 := sess.DB(util.MgoS.DbName).C("spider_listdata").Find(&query).Iter()
|