Mongo Db。管道查询不正确
MongoDB是一种开源的、面向文档的NoSQL数据库管理系统。它使用JSON样式的文档来存储数据，具有高度的灵活性和可扩展性。MongoDB的管道查询是一种强大的查询工具，可以通过将多个操作连接在一起来处理和转换数据。
管道查询是MongoDB中的一种数据聚合框架，它允许用户通过将多个阶段连接在一起来处理和转换数据。每个阶段都会对输入数据进行处理，并将结果传递给下一个阶段，最终生成所需的输出结果。管道查询可以用于各种复杂的数据处理任务，如数据过滤、排序、分组、聚合、投影等。
管道查询的优势包括：
- 灵活性：管道查询提供了丰富的操作符和阶段，可以根据具体需求进行灵活的数据处理和转换。
- 高效性：管道查询可以利用MongoDB的索引和聚合操作来优化查询性能，提高数据处理效率。
- 可扩展性：由于管道查询可以将多个阶段连接在一起，可以轻松地扩展和调整查询流程，以适应不同的数据处理需求。
MongoDB的管道查询在各种应用场景中都有广泛的应用，例如：
- 数据分析和报表生成：通过管道查询可以对大量数据进行聚合、分组和计算，生成各种统计报表和分析结果。
- 实时数据处理：管道查询可以用于实时数据流处理，对数据进行过滤、转换和聚合，以满足实时业务需求。
- 数据清洗和转换：通过管道查询可以对原始数据进行清洗、转换和格式化，以便后续的数据处理和分析。
- 数据迁移和同步：管道查询可以用于将数据从一个集合或数据库迁移到另一个集合或数据库，并保持数据的一致性和完整性。
腾讯云提供了MongoDB的托管服务，称为TencentDB for MongoDB。它提供了高可用性、高性能和可扩展的MongoDB数据库实例，支持自动备份、监控和故障恢复等功能。您可以通过以下链接了解更多关于TencentDB for MongoDB的信息：https://cloud.tencent.com/product/mongodb
相关·内容
2回答
我有一个想要查询的mongoDB。我知道如何在sql中这样做，但不确定如何在MongoDB中这样做。
select distinct value, type, array_agg(distribution) as distributions
from t
group by value, param_type;
我正在尝试，但不断地出错：
db.getCollection('test').aggregate([
{
$group: {
_id: {
"type": "$type",
"
浏览 5提问于2021-03-25得票数 0
回答已采纳
我有一个位置集合，并希望检索顶级父位置。例如，如果我按id 4查询位置，则应该返回id 1的位置。
{_id: "1", "parentLocationID": null, "childLocationIds": [2]}
{_id: "2", "parentLocationID": "1", "childLocationIds": [3]}
{_id: "3", "parentLocationID": "2", "childL
浏览 1提问于2017-09-20得票数 0
回答已采纳
我正在尝试从多个文档中查找字段的最大值，并希望输出不仅反映字段的最大值，还反映聚合查询将检索的文档的总数。
对于下面的查询，我能够检索到具有我想要的最大值的"wait“字段，但是遇到了如何获取满足以下查询的所有文档的计数(Match字段)的问题。
db = mongo_client[_MONGO_COLLECTION]
cursor = db.aggregate(
[
{"$match": { "owner": { "$exists": False}}},
浏览 0提问于2019-10-03得票数 0
2回答
我想用where子句在MongoDB中创建一个MAX查询。
我试试这个
db.Collection.aggregate({$group : {_id : "$P_ID", massi : {$max : "$b_val"}}},{P_ID:'XYZ',experiment:'abc'});
我的WHERE子句是{P_ID:'XYZ',experiment:'abc'}
我不知道为什么，但这个查询不能工作，请获得以下错误：
assert: command failed: {
"ok&#
浏览 6提问于2016-10-15得票数 1
回答已采纳
我已经将mongo查询转换为symfony4原则odm查询。为此，我使用。它不会返回任何东西并抛出内存异常。
注意:即使我也增加了php的限制，也面临着同样的问题。
请查找以下代码：
Shell Mongo查询：
db.Article.aggregate([
{
$group: {
_id: { department: "$department" },
count: { $sum: 1 }
}
},
{
$sort: {
salar
浏览 1提问于2019-01-22得票数 0
我想在mongo db中使用外部file.js执行查询
我确实试过这个：
mongo < query.js
或
cat query.js| mongo
这些方法都是有效的，但我喜欢使用pretty()。
浏览 1提问于2014-07-15得票数 1
1回答
我想使用地理空间geoNear，数据库中的mongodb，Mongo查询：
db.runCommand(
{
geoNear: "tmp",
near: { type: "Point", coordinates: [ 77.00000, 12.00000] },
spherical: true,
maxDistance : 200
}
)
给出了mongo终端的结果，但是如何使用node.js来执行它?我正在使用mongo池和通用池来实现mongo池？
浏览 1提问于2015-03-25得票数 4
很抱歉问了个基本问题，我不熟悉蒙戈，也不知道该怎么做。
我在Mongo中运行了一个聚合查询：
> var result = db.urls.aggregate({$group : {_id : "$pagePath"} });
> result
{ "_id" : "/section1/page1" }
{ "_id" : "/section1/page2" }
...
Type "it" for more
现在，我想将这个聚合查询的结果保存到一个新集合中。这就是我尝试过的：
>
浏览 2提问于2014-12-17得票数 1
回答已采纳
我正在我的mongo集群上运行一个groupBy query。我正在使用在线工具。运行查询后，我将得到一个错误。数据大小很大。有绕道的路吗？
// SQL query
SELECT COUNT(*) AS count FROM db_name
WHERE version="v2"
GROUP BY id
// Mongo query
db.db_name.group({
"key": {
"id": true
},
"initial": {
"count": 0
},
"reduce&
浏览 7提问于2020-05-19得票数 0
回答已采纳
当我使用聚合排序时，我得到了错误代码为16819的mongo错误exceeded memory limit。
我使用的是mongo 2.6。
查询如下：
db.BASE_TABLE_CREATION_ExecuteHiveScript_26_V0.aggregate([
{ "$project" : { "visitor_localdate" : 1 , "_id" : 0}},
{ "$sort" : { "visitor_localdate" : -1}}
])
浏览 4提问于2014-10-15得票数 23
我有一个Mongo DB查询，需要使用MongoEngine转换。考虑下面的查询，我想在MongoEngine ORM中实现相同的查询。我对MongoDB和MongoEngine非常陌生。提前感谢 db.my_collection.aggregate([
{
$unwind:"$quizzes"
},
{
$group:{
"_id":"$quizzes.skill",
"k":{
$f
浏览 19提问于2019-09-05得票数 0
1回答
我正在尝试在一个MongoDB集合上创建一个组查询，类似于：
db.orders.group( {
key: { ord_dt: 1, 'item.sku': 1 },
cond: { ord_dt: { $gt: new Date( '01/01/2012' ) } },
reduce: function ( curr, result ) { },
initial: { }
} )
我使用的是rmongodb。通过查看rmongodb包文档，他们使用mongo.command来运行计数命令：
mongo <- mongo.
浏览 5提问于2012-11-28得票数 2
在通过MongoDB使用C#聚合框架时，我遇到了性能问题。在使用C#执行时，通过Mongo快速工作的聚合要花费很长时间。
在尝试通过C#调用框架之前，我通过Mongo执行了以下聚合，以检查所有操作是否正常：
db.runCommand(
{
aggregate: "actions",
pipeline :
[
{ $match : { CustomerAppId : "f5357224-b1a8-4f1a-8ea2-a06a00ca597a", ActionName : "
浏览 7提问于2012-10-08得票数 2
回答已采纳
假设我有一个带有时间戳字段的mongo集合中的文档。我想根据时间戳值(大于、小于)查询文档。为了做到这一点，我希望在查询中嵌入从日期到时间戳的转换，而不是每次都计算当前日期的时间戳。我尝试了这样的方法(假设"ts"是我的时间戳字段)： db.my_collection.find({"ts": {$lt: {$toLong : new Date("2020-12-09")}}}) 而不是做： db.my_collection.find({"ts": {$lt: 1578524400}}) 但它似乎返回了一个空结果。 在查询中是否有
浏览 113提问于2020-12-09得票数 0
2回答
这是一个技术性能问题：
我有这样的疑问
db.collection.aggregate([
{$match:{...}},
{$group:{...}},
{$group:{...}},
{$project:{...}},
{$sort:...}
])
但是，如果我想设置限制，则在查询的最后使用$limit
db.collection.aggregate([
{$match:{...}},
{$group:{...}},
{$group:{...}},
{$project:{...}},
{$sort:...},
浏览 2提问于2015-07-17得票数 1
回答已采纳
1回答
我在Mongo中执行查询，并要求该查询的输出来执行第二个查询。第一个查询是用于查找平均值的聚合查询。
第一个查询是：
db.table_name.aggregate([{$group: {_id:{userId:'$userId'},avgRating:{$avg:"$rating"}}}])
现在，在输出中使用_id (userId)，我想从user表中获取数据。
浏览 1提问于2016-09-27得票数 1
回答已采纳
我正在尝试使用多关键字索引来按另一个关键字查找最新记录。我似乎不能让它表现出来。
在伪sql中，我会说
create table my_table (user_id int, post_time timestamp, content text);
create index my_index (user_id,post_time) on my_table;
然后，我可以点击索引，为每个用户找到最新的post_time
select user_id,max(post_time) from my_table group by user_id
即使有数百万条记录，数据也将来自索引，而我们根本不会命中表
浏览 1提问于2015-02-06得票数 1
我试图在pymongo连接器中插入查询对象：
import pandas as pd
from pymongo import MongoClient
def _connect_mongo(host, port, username, password, db):
if username and password:
mongo_uri = 'mongodb://%s:%s@%s:%s/%s' % (username, password, host, port, db)
conn = MongoClient(mongo_uri)
浏览 3提问于2016-08-30得票数 0
回答已采纳
我有一个a集合，它将树数据存储为带有父引用的mongo db文档，如https://docs.mongodb.com/manual/tutorial/model-tree-structures-with-parent-references/中所述。 我的问题是，如何使用mongodb查询删除一个节点(文档)以及该节点下的所有文档(子节点的子节点等)。我不想解析和获取所有的I，然后删除它们。有没有任何mongo mongo查询可以帮助我删除整个子树，以父引用作为开始参数。 提前感谢！ 干杯
浏览 15提问于2020-11-28得票数 1
回答已采纳
我正在尝试从Mongo DB中提取文档，基于字段'Type‘，并在结果中指定顺序。可以正确检索结果，但结果不会保留查询中给出的字段顺序。 我已经在下面包括了工作代码片段，有人可以帮助我如何更新基于我的代码片段的等效Java代码。 Mongo query is as below :- (Which retrieves data)
==========================================
db.getCollection('elements').aggregate([
{$match : {'Type'
浏览 93提问于2019-01-09得票数 0
回答已采纳
1回答
我试图使用他们的nodejs驱动程序在Mongo中运行一个聚合查询，这会占用我的一些字段，并添加/查找平均值等等。我在Mongo中构建了聚合并将其导出到节点，但是当我运行代码时，我从Mongo获得了以下响应：
this.res无法序列化。steps.update_mongo.res:null
下面是代码(历史字段是一个对象数组)：
const agg = [
{
'$addFields': {
'avgGrowth': {
'$ceil': {
'$avg':
浏览 3提问于2021-01-15得票数 0
我收集了一些具有大致如下结构的归档任务
{
"_id" : "job-id_00000001_2017-03-17T21:30:38.510Z",
"jobId" : "job-id",
"result" : {
"status" : "ok"
},
"..." : "..."
}
最重要的是我有索引
jobId: 1
result.status: 1
jobId: 1, result.statu
浏览 2提问于2017-03-21得票数 2
嗨:我在用聚合查询替换mongo独特的“原生”函数时遇到了一些问题。 在我的例子中，我的查询如下： db.collection.distinct('stuff.shape') 然后，mongo返回一个具有不同object.field值的数组，如下所示 ['square','triangle','circle'] 但是用聚合体遮蔽 db.collection.aggregate([
{ $match:{ 'stuff.shape':{$exists: true} } },
{ $group:{ '
浏览 49提问于2020-07-07得票数 0
回答已采纳
1回答
我在mongodb中有以下数据库：
{"Team":{"_id":{"$oid":"5a465ca9150ed3f847f01b92"},"TeamName":"NA"}}
{"Card":{"_id":{"$oid":"5a46626e150ed3f847f01bac"},"Number":1,"Page":1,"Team":[{"$oid":"5a465ca91
浏览 1提问于2018-01-02得票数 3
回答已采纳
在我当前的项目中，我有以下文档结构： [
{
"_id": {"$oid": "5f9a7ed94fea7938c6015e03"},
"ADDRESSES": [
{
"STREET_NUMBER": 99,
"STREET": "Barkey",
"CITY": "Wilmington Island",
"COUNTRY": "Austria"
}
],
"BIRTH
浏览 51提问于2020-11-02得票数 1
1回答
无法附加json数据。
、、、
我试图执行mongo查询和mysql查询，结果都验证并返回到变量中。我的问题是它只返回mysql数据。没有附加到mongo结果。如果我放置console.log，那么它就是在显示，但作为回报，它不是。请让我知道在下面的代码丢失的地方。
var message= {'msg':gloabl_vars.messages.success,'mysql':{'msg':'success','data':[]},'mongo':{'msg':'success','
浏览 1提问于2018-11-01得票数 0
回答已采纳
我正在尝试将以下mongoDB查询与一起使用，但无法将其作为raw查询运行。
db.getCollection('users').aggregate([
{
"$group": {
"_id": { "cnic": "$cnic", "time_in": "$time_in" },
"uniqueIds": { "$addToSet": "$_id" },
浏览 0提问于2016-11-16得票数 4
我是mongodb的新手，第一次尝试了聚合。在这里，我试图得到每15分钟分组的推文数量。当我试图在mongo控制台中运行以下查询时，会得到以下错误：
管道级规范对象必须精确地包含一个字段。
db.hashtag.aggregate([
{ "$group": {
"_id": {
"year": { "$year": "$tweettime" },
"dayOfYear": { "$dayOfYear&#
浏览 2提问于2017-02-14得票数 37
回答已采纳
1回答
我试图把所有我正在收集的数据放到MongoDB中来监控房价。我已经做了很多测试，但都不起作用了。如果有人能帮我的话，我会把密码放在这里。请。
init.py
import scrapy
from realstatedata.items import RealstatedataItem
class RsdataSpider(scrapy.Spider):
name = 'realstatedata'
allowed_domains = ['vivareal.com.br']
start_urls = ['https://www.
浏览 0提问于2021-08-18得票数 0
回答已采纳
我正在用mongo shell编写一个$or查询
db.collectionName.find({$or:[{ fullName: { $regex: "a",$options:"i"}},{ fullName: { $regex: "b",$options:"i"}}]}).pretty();
它为我提供了与a或b的并集匹配的文档。但是我们还能找到查询的工作和结果是哪个值吗？例如，对于第一个正则表达式，即"a“，我得到一个单独的结果；对于另一个正则表达式，即"b”，我得到一个单独的结果
浏览 0提问于2021-02-08得票数 0
我正在使用：
db.version()
3.2.3
版本()
3.2.0-17-gde480c0
db.getCollection('events').aggregate([
{ $concat: [ "$element", " - ", "$Eventtype" ] }
])
出现以下错误：
"assert: command failed: {
"ok" : 0,
"errmsg" : "Unrecognized pipeline stage nam
浏览 9提问于2016-09-09得票数 0
回答已采纳
2回答
我的mongodb集合如下所示：
{
"_id" : ObjectId("5333bf6b2988dc2230c9c924"),
"name" : "Mongo2",
"notes" : [
{
"title" : "mongodb1",
"content" : "mongo content1"
浏览 11提问于2014-03-27得票数 1
回答已采纳
当我试图在PHP中聚合一个集合时，会出现一个错误。集合"lbls2“包含如下文档：
{
"_id" : ObjectID(1234),
"values" : ["String 1", "String 2", "String 3"]
}
{
"_id" : ObjectID(5678),
"values" : ["String 1", "String 4", "String 7"]
}
{
浏览 2提问于2016-06-03得票数 0
回答已采纳
我正在创建一个mongo聚合查询，它在我的$subtract块中使用了一个$match操作符。如以下代码所述。
这个查询不工作：
db.coll.aggregate(
[
{
$match: {
timestamp: {
$gte: {
$subtract: [new Date(), 24 * 60 * 60 * 1000]
}
}
}
},
{
$group: {
浏览 6提问于2015-03-09得票数 6
回答已采纳
我想从mongo db字段中提取一个子字符串，并检查它是否能被4整除。
我有一些类似下面的文档：
{
"form" : "form-1002",
"requestType" : "POST"
},
{
"form" : "form-1003",
"requestType" : "POST"
}
我想提取基于表单字段的文档，如form-1002，1002可以被2整除，然后根据查询结果更新请求类型。我如何才能做到这一点？
浏览 0提问于2018-09-11得票数 1
当被特定字段查询时，有没有办法在mongo Db集合中找到重复记录(所有重复记录的出现)？我使用的是Spring-data。在SO中也有类似的问题：
但是我想要重复的值(文档)，而不是计数。这个是可能的吗？
浏览 1提问于2018-09-11得票数 2
所以我对node.js有点陌生。我不明白为什么聚合查询不适合我。我曾在Mongo上尝试过相同的查询，它运行得很好。下面是代码：
db.collection("companies").aggregate({$match:
{$or:
[{ $and:
[{ left: {$gt: 2}}, {left: {$lt: 11}}]},
{ $and:
[{ right: {$gt: 2}}, {right: {$lt: 11}}]}]}},
{ $group:
{_id:null,
Sum:{$sum:
浏览 9提问于2017-09-23得票数 0
回答已采纳
1回答
我正在尝试从Mongo数据库中提取特定的子元素。我使用了一组样本数据，其中包含了“圣经”中的所有书籍和经文。我需要查询和显示一个单独的诗句。 数据如下所示： {"book": "1 Chronicles",
"chapters": [
{"chapter": "1",
"verses": [
{"verse": "1", "text":
浏览 7提问于2020-10-29得票数 0
2回答
如果我执行计数查询，则在<2秒内得到结果
db.coll.find({"A":1,"createDate":{"$gt":new Date("2011-05-21"),"$lt":new Date("2013-08-21")}}).count()
这使用了以下索引
db.coll.ensureIndex({"A":1,"createDate":1})
类似地，有4列A、B、C、D(值总是0或1)，对这些列我运行4个计数查询，并在<10秒内获得结果。
我查看
浏览 5提问于2014-02-21得票数 5
场景是Employee，它们在多个Store位置工作，并将这两个集合组合在一起，这是非常完美的，
问题：在特定位置搜索(输入lat，long)，这个查询将提供在特定存储上工作的特定员工，而location字段在查找集合中。
员工
{
"_id": ObjectId("5f03064b3460ef1f10ec2f25"),
"employeeName": "Anonymous",
"stores": [
{
"storeId": ObjectId("5f
浏览 7提问于2020-07-08得票数 1
回答已采纳
我想问一下，在mongo db中查询更好，如下所示：
db.users.findOne({'username': 'example', 'password': '5f189664bb2e58d4e2ee879835b13a7e3a790e14'})
或者在if条件下检查密码散列，如下所示：
user = db.users.findOne({'username': 'example'})
if user['password'] == passwordHash:
print &#
浏览 0提问于2011-03-06得票数 1
回答已采纳
Frinds我有以下Mongo查询来选择一个随机记录并使用merge返回更新的记录
db.collection.aggregate([
{
$match: {
"lastAccessed": {
$exists: false
}
}
},
{
"$sample": {
"size": 1
}
},
{
$set: {
tableName: "myTable",
lastAccessed: "
浏览 4提问于2022-02-16得票数 0
回答已采纳
1回答
我在mongo group查询中遇到了一个问题：(这是PHP代码)
$conditions = array(
'user' => array(
'$ne' => $uid
)
);
$group = $db->words->group(
array("word" => true),
array(
浏览 0提问于2012-06-29得票数 0
回答已采纳
1回答
我对Mongo (一个喜欢SQL的家伙)很陌生，并且在别人设置的应用程序中工作。我有这样的记录，还有更多的信息：
City:
name: "name"
State: ObjectId({id here})
slug: "slug"
images: [images]
...
而且state也有一个文本字段，其中包含段塞。我想为相关城市创造一个新的条目。因此，它将是一个数组的图像，鼻涕虫，状态鼻涕虫，和名称。我尝试了以下方法，但最后得到了stateSlug的查询信息：
db.getCollection('city
浏览 3提问于2016-09-25得票数 1
回答已采纳
我有一个类似于以下的查询；
db.getCollection('list').aggregate([
{
$facet: {
"events":[{
$match: {
'type': 'Event'
}
}],
"tasks": [{
$match: {
浏览 0提问于2021-03-15得票数 0
回答已采纳
我想使用数组字段第0值来使用Mongo聚合$lookup查询在销售文档中查找匹配项。以下是我的疑问：
db.products.aggregate([
{
$match : { _id:ObjectId("57c6957fb190ecc02e8b456b") }
},
{
$lookup : {
from : 'sale',
localField: 'categories.0',
foreignField: 'saleCategoryId',
浏览 2提问于2016-09-01得票数 6
回答已采纳
2回答
我有一个mongo查询，它在我的生产服务器上运行得很好。但它不会在我的开发服务器上返回结果。我在开发服务器上的数据库是实时数据库的副本。
Prod - AWS：
mongo v3.0.7
开发人员-数字海洋
mongo v3.0.9
Mongo查询(使用RoboMongo运行)-无序性的坐标掩蔽;)
db.getCollection('$cmd').findOne({
"geoNear": "ProviderData",
"near": [
XX.1325611,
XX.1357446
],
浏览 0提问于2016-08-10得票数 1
3回答
有没有可能在Mongo DB中使用2个或更多类似于SQL查询的集合来编写联合查询？
我使用的是spring mongo模板，在我的用例中，我需要根据一些条件从3-4个集合中获取数据。我们可以在一次操作中实现这一点吗？
例如，我有一个名为"circuitId“的字段，它在所有4个集合中都存在。我需要从所有4个集合中获取该字段与给定值匹配的所有记录。
浏览 0提问于2017-09-07得票数 8
回答已采纳
我正在用mongo db写一个查询。我想知道如何在find函数中使用substring函数，就像我有一个日期字符串一样。我想按年过滤日期，然后按月分组。这是我尝试过的：
db.booking.find({$substr:["$bookingdatetime",5,2]:"14"}).aggregate([ {$group: { _id: {$substr: ['$bookingdatetime', 5, 2]}, numberofbookings: {$sum: 1} }} ])
我哪里错了？
浏览 2提问于2014-12-09得票数 0
1回答
我一直在为Mongo查询使用Java语法。
我已经为控制台编写了Mongo查询，但我希望为该查询提供相应的Java语法。
下面是shell命令：
db.errorsegmentaudit.aggregate([
{$sort:{timestamp:1}},
{$limit:1},
{$unwind:"$auditErrorTypeCounts"},
{$unwind:"$auditErrorTypeCounts.auditErrorCounts"},
{$group: {
_id: {
浏览 0提问于2018-04-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
