草庐IT

mongodb 统计子文档并列出总计

全部标签

mongodb - 在 mgo 中更新多个数组中的单个子文档

我有以下mongodb(3.4.x)文档,我使用mgo驱动程序在golang中编码{"id":"5981d4c2795a1b4a801ee027","scenarioId":"59804b10d8ee910085e33865","messages":[{"id":"5981d4c2795a1b4a801ee028","toQueue":[{"id":"5981d4c2795a1b4a801ee029","to":{"email":"some@email.com"},"channel":"EMAIL","toType":"EMAIL","status":{"id":1,"groupId"

mongodb - 使用 Golang 在 MongoDB 中无循环地更新文档

我有一个收集器模块,每30秒提取一次远程API。这为我提供了在MongoDB数据库中插入或更新的对象列表。{"id":"oulkhhvoiupokb","name":"test1","status":"OPEN"},{"id":"oulkhhvoisksbsjkkb","name":"test2","status":"CLOSED"}事实上,我只收集具有OPEN状态的对象。通过一个循环,我将对象的其余部分设置为关闭(因为它们不是打开的)。但是以后会需要很多时间,因为object的amont会越来越大。我使用Golang和MGO包。有没有办法更快更干净地完成它?比如为Mongo文档设置基

MongoDB 在 golang 中使用 $or 和 $and 的组合查找查询

我想在以下位置获取行:{repairfieldhas"ac"OR{repairis"tv"andphonefieldinrange1091-1100}}我正在尝试以下查询:typeMmap[string]interface{}conditions:=M{"name":M{"$regex":"me"},"$or":[]M{M{"repair":M{"$eq":"ac"}},"$and":[]M{M{"repair":M{"$eq":"tv"}},M{"phone":M{"$gte":1091,"$lte":1100}}}}}fmt.Println(conditions)err=c.Fin

mongodb - 如何在 MongoDB 中执行带有搜索的 Joinquery 然后继续?

大家好,我正在做一个客户可以发送帐户停用请求的项目,作为管理员,我可以看到列表并在页面上停用它们,在同一页面上我有一个搜索过滤器,可以按姓名、电子邮件和电话号码进行过滤。我有一个集合来保存客户,另一个集合来保存停用请求。我已经完成了列表部分,因为它使用选择查询很简单,但面临通过搜索过滤器获取列表的问题,我在Golang中有以下2个结构来获取记录:typeDeactivationRequeststruct{Idint`json:"id"bson:"id"`Uidint`json:"uid"bson:"uid"`RequestTimeint64`json:"request_time"bso

mongodb - Mongo 授权数据库失败

我在本地主机中有一个启用了安全性的mongo实例。和用户如下,db.createUser({user:"mongouser",pwd:"pass",roles:[{role:"userAdminAnyDatabase",db:"admin"},{role:"readWriteAnyDatabase",db:"admin"},{role:"dbAdminAnyDatabase",db:"admin"},{role:"clusterAdmin",db:"admin"}]});我正在尝试使用mgo连接到名为testDatabase的数据库,如下所示mongoConnectionUrl="mo

mongodb - 在 MongoDB 中基于 ID 对两个集合执行连接

我有两个集合:评分和预订。在预订集合中,我有一个字段“_id”,它是正常的文档ID。我还在预订集合中保存了一个字段“location_id”。在收视率收集中,我将预订的ID引用为“booking_id”字段。查询1:我想根据“location_id”计算评分,这意味着首先我需要根据location_id获取预订,然后我需要找到该预订的评分(位置为“location_id”).为此,我通过像这样聚合两个集合来执行MongoDB连接:getCollection:=mongoSession.DB(config.Database).C(config.RatingsCollection)pipe

mongodb - 使用 golang 从已经运行的集群的主实例重播另一个 mongodb 实例中的 oplog

我正在以json格式存储来自正在运行的主要mongodb实例的操作日志[{"Timestamp":6477723955623886852,"HistoryID":166676398345289971,"MongoVersion":2,"Operation":"i","NameSpace":"test.tests","Object":{"__v":0,"_id":"59e57f9e8489535b1848d32d","num":9795},"QueryObject":null},{"Timestamp":6477723955623886853,"HistoryID":3344156456

mongodb - Golang mgo 获取空对象

我正在尝试学习GoAPI开发。我有一个在Docker容器中运行的MongoDB实例。我正在尝试遵循一些指南,但在简单查询时失败了。我不完全理解这里的BSON和JSON标签的使用。我知道这些术语的意思。所以这是我的代码。import("fmt""time""gopkg.in/mgo.v2/bson")const(hosts="localhost:27017"database="my_database"username="dev1"password="password123"collection="users")typeusersstruct{userstring`bson:"user"j

mongodb - 使用 Gin 和 JobRunner

我正在使用JobRunner用于我的Golang项目的调度程序和Gin-gonic框架。我已经尝试过这个包并且它有效。问题是,当我想连接到我的数据库时,我无法访问调度函数中的gin上下文funcScheduleUrl(){jobrunner.Start()//optional:jobrunner.Start(poolint,concurrentint)(10,1)jobrunner.Schedule("@every20s",CheckExpiredUrl{})}//JobSpecificFunctionstypeCheckExpiredUrlstruct{//filtered}//Re

mongodb 聚合在 golang 中给出错误

我想要分组方法类型并根据它们的类型对它们进行计数。这些方法是字符串。我写了下面的代码。但是它给出了一个错误。pipeline:=[]bson.D{bson.D{{"$unwind","$method"},},bson.D{{"$group",bson.M{"_id":"$method","count":bson.M{"$sum":1}}},},query:=bson.D{{"aggregate","API_ACCESS_LOGS"},//useragentsisacollectionname{"pipeline",pipeline},}err=session.DB("vamps-log