pymongo相关内容

MongoDB - 在几个小时的时间范围内查询

我设置了一个 MongoDB 数据存储,其中的位置数据存储如下: {"_id" : ObjectId("51d3e161ce87bb000792dc8d"),"datetime_recorded" : ISODate("2013-07-03T05:35:13Z"),“位置":{“坐标":[0.297716,18.050614],“类型":“点"},“视频":“11111-22222-33333- ..
发布时间:2021-12-05 18:37:17 其他开发

如何使用 pymongo 在 mongodb 中创建查询日期?

我正在尝试在 mongodb 中执行查询日期,但结果始终为空.我的查询如下: //在开始代码中def __init__(self):self.now = datetime.now()self.db = conexaoMongo()self.horaInicio = self.now - timedelta(minutes=1)def resultadoConsulta(self, modo, p ..
发布时间:2021-12-05 18:35:07 Python

在单个查询中从 mongo 中删除多个文档

我有一个要删除的 mongo '_id' 列表.目前我正在这样做 # inactive_users -->非活动用户列表对于 inactive_users 中的项目:db.users.remove({'_id': item}) 但我的问题是列表太大了......(可能会超过 100,000).所以查询列表中的每一项只会增加服务器的负载.是他们在 mongo 查询中传递整个列表的一种方式,这样我 ..
发布时间:2021-12-05 18:34:42 其他开发

pymongo 中的快速或批量 Upsert

如何在 pymongo 中进行批量更新?我想更新一堆条目并且一次执行一个非常慢. 这里有一个几乎相同问题的答案:MongoDB 中的批量更新/upsert? 接受的答案实际上并未回答问题.它只是提供了一个链接到 mongo CLI 以进行导入/导出. 我也愿意向其他人解释为什么无法进行批量更新插入/不是最佳实践,但请解释此类问题的首选解决方案是什么. 解决方案 现代版本的 ..
发布时间:2021-12-05 18:33:29 Python

使用 PyMongo 将 Pandas Dataframe 插入 mongodb

使用 PyMongo 将 Pandas DataFrame 插入 mongodb 的最快方法是什么? 尝试 db.myCollection.insert(df.to_dict()) 出现错误 InvalidDocument:文档必须只有字符串键,键是时间戳('2013-11-23 13:31:00', tz=None) db.myCollection.insert(df.to_ ..
发布时间:2021-12-05 18:22:32 Python

如何使用 pymongo 对 mongodb 进行排序

我在查询 mongoDB 时尝试使用排序功能,但它失败了.相同的查询在 MongoDB 控制台中有效,但在此处无效.代码如下: 导入pymongo从 pymongo 导入连接连接 = 连接()db = connection.myDB打印 db.posts.count()对于 db.posts.find({}, {'entities.user_mentions.screen_name':1}).s ..
发布时间:2021-12-05 18:13:40 Python

如何使用 insert_many 安全地忽略重复的键错误

在 pymongo 中使用 insert_many 时,我需要忽略重复插入,其中重复基于索引.我在 stackoverflow 上看到过这个问题,但我还没有看到有用的答案. 这是我的代码片段: 尝试:结果 = mongo_connection[db][collection].insert_many(documents,ordered=False,bypass_document_valida ..
发布时间:2021-12-05 18:12:05 Python

使用 pymongo 在 mongodb 中按 ObjectId 搜索

我需要使用 pymongo 使用 python 搜索 ObjectId,但我总是收到此错误.任何想法如何搜索? 导入pymongo从 pymongo 导入 MongoClient从 pymongo 导入 ObjectIdgate = collection.find({'_id': ObjectId(modem["dis_imei"])})打印门回溯(最近一次调用最后一次):文件“C:\Users ..
发布时间:2021-12-05 18:04:28 Python

如何在 MongoDB 中使用“Not Like"运算符

我可以使用 SQL Like 操作符使用 pymongo, db.test.find({'c':{'$regex':'ttt'}}) 但是我如何使用 Not Like 操作符? 我试过了 db.test.find({'c':{'$not':{'$regex':'ttt'}}) 但出现错误: OperationFailure: $not 不能有正则表达式 解决方案 来自 ..
发布时间:2021-12-05 17:57:39 其他开发

在日期时间的月、日、年...上查询 Mongodb

我正在使用 mongodb 并以这种方式将日期时间存储在我的数据库中 对于我存储的日期“17-11-2011 18:00": date = datetime.datetime(2011, 11, 17, 18, 0)db.mydatabase.mycollection.insert({“日期":日期}) 我想做这样的请求 月 = 11db.mydatabase.mycollection ..
发布时间:2021-12-05 17:54:35 Python

mongo - 无法连接到服务器 127.0.0.1:27017

我来自 riak 和 redis,在那里我从未遇到过此服务启动或交互的问题. 这是 mongo 普遍存在的问题,而且我相当无能为力.重新启动没有帮助.我是 mongo 的新手. mongoMongoDB 外壳版本:2.2.1连接到:测试11 月 9 日星期五 16:44:06 错误:无法连接到服务器 127.0.0.1:27017 src/mongo/shell/mongo.js:91异常 ..
发布时间:2021-12-05 17:51:17 其他开发

使用 PyMongo 执行正则表达式查询

我正在尝试使用 PyMongo 对 MongoDB 服务器执行正则表达式查询.文档结构如下 {“文件":[“文件 1",“文件2",“文件3",“档案4"],“rootFolder":“/Location/Of/Files"} 我想获取所有与 *File.txt 匹配的文件.我试着这样做 db.collectionName.find({'files':'/^File/'}) 然而我什么也得 ..
发布时间:2021-12-05 17:48:31 其他开发

你能在 Mongo 中为 $addToSet 指定一个键吗?

我有一个文件: { 'profile_set' :[{ 'name' : 'nick', 'options' : 0 },{“名称":“乔",“选项":2},{“名称":“伯特",“选项":1}]} 如果名称不存在(无论选项如何),则希望将新文档添加到 profile_set 集合中. 所以在这个例子中,如果我尝试添加: {'name' : 'matt', 'options' : ..
发布时间:2021-12-05 17:36:39 其他开发

如何将数据从 mongodb 导入到 Pandas?

我在 mongodb 的集合中有大量数据需要分析.我如何将该数据导入熊猫? 我是 Pandas 和 numpy 的新手. 编辑:mongodb 集合包含用日期和时间标记的传感器值.传感器值是浮点数据类型. 样本数据: {"_cls": "传感器报告","_id" : ObjectId("515a963b78f6a035d9fa531b"),“_类型":[《传感器报告》],“阅读 ..
发布时间:2021-12-03 09:23:24 Python

抽象类和 PyMongo;无法实例化抽象类

我创建了空抽象类 AbstractStorage 并从它继承了 Storage 类: 导入 abc将 pymongo 导入为 mongo主机 = mongo.MongoClient()打印(host.alive()) # 真类抽象存储(元类= abc.ABCMeta):经过类存储(抽象存储):dbh = 主机def __init__(self):打印('__init__')贮存() 我希望输出 ..
发布时间:2021-11-26 17:09:01 Python

抽象类和 PyMongo;无法实例化抽象类

我创建了空抽象类 AbstractStorage 并从它继承了 Storage 类: 导入 abc将 pymongo 导入为 mongo主机 = mongo.MongoClient()打印(host.alive()) # 真类抽象存储(元类= abc.ABCMeta):经过类存储(抽象存储):dbh = 主机def __init__(self):打印('__init__')贮存() 我希望输出 ..
发布时间:2021-11-25 09:40:50 C#

Pymongo API TypeError: Unhashable dict

我正在为我的软件编写 API,以便更轻松地访问 mongodb. 我有这条线: def update(self, recid):self.collection.find_and_modify(query={"recid":recid}, update={{"$set": {"creation_date":str( datetime.now() ) }}} ) 抛出 TypeError: ..
发布时间:2021-11-15 01:16:28 其他开发

让 Spark、Python 和 MongoDB 协同工作

我很难将这些组件正确地组合在一起.我已经安装并成功运行了 Spark,我可以在本地、独立以及通过 YARN 运行作业.我遵循了建议的步骤(据我所知)这里 和 这里 我正在开发 Ubuntu,我拥有的各种组件版本是 Spark spark-1.5.1-bin-hadoop2.6 Hadoop hadoop-2.6.1 Mongo 2.6.10 Mongo-Hadoop 连接器 从 ..
发布时间:2021-11-12 05:35:26 其他开发

使用嵌套字段中的值更新字段

我知道我可以在 update 中使用管道聚合器来用另一个字段的值更新一个值的字段.但是,我的问题是基于嵌套字段的值更新字段值时.更新的结果总是发出带括号的新字段.我不想要括号/数组,我只想要它是一个值.见下面的代码https://mongoplayground.net/p/7ZDP8CYtKK3 db={“玩家":[{“_id":ObjectId(“5fba17c1c4566e57fafdcd7 ..
发布时间:2021-10-26 17:49:59 其他开发