需要Mongo查询才能从mongodb获取文档中多个字段的计数
在MongoDB中，可以使用聚合管道操作符来实现查询并获取文档中多个字段的计数。聚合管道操作符提供了一组灵活的工具，用于对数据进行处理、转换和组合。
以下是一个示例的聚合管道操作，可以用于获取文档中多个字段的计数：
db.collection.aggregate([
{
$group: {
_id: null,
countField1: { $sum: { $cond: [{ $gt: ["$field1", null] }, 1, 0] } },
countField2: { $sum: { $cond: [{ $gt: ["$field2", null] }, 1, 0] } },
countField3: { $sum: { $cond: [{ $gt: ["$field3", null] }, 1, 0] } }
// 添加需要计数的其他字段...
}
},
{
$project: {
_id: 0
}
}
])在上述示例中，db.collection 是你要查询的集合名称。$group 阶段通过使用 $sum 和 $cond 等聚合操作符来计算每个字段的计数。你可以根据需要添加其他字段。在 $project 阶段，我们去掉了结果中的 _id 字段。
关于MongoDB的聚合管道操作，可以参考腾讯云的 MongoDB 聚合查询文档。
相关·内容
每当我使用explain对MongoDB运行count查询时，我都可以看到两个不同的阶段COUNT_SCAN和IXSCAN。我想知道它们之间的性能差异，以及如何改进查询。字段已编入索引。
查询字段(True)字段({db.collection.explain:1}})使用COUNT_SCAN和query like
db.collection.explain(true).count({field:"$in":1,2})使用IXSCAN。
浏览 0提问于2018-03-29得票数 5
1回答
我试图使用mongo存储库返回一个整数，我想得到的值是id，下面是mongo查询，用于将id字段作为整数从数据库中提取出来。
package com.example.messagestomongodb.repository;
import com.example.messagestomongodb.domain.CovidCases;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.data.mongodb.repository.Query;
impo
浏览 16提问于2022-09-24得票数 0
回答已采纳
1回答
我正在努力处理一个MongoDb查询。 我有一个查询，可以对一些字段进行分组和计数，例如： field_name | count
___________________
field1 | 10
field2 | 20
field3 | 30 我还想在末尾添加总计数，使其看起来像这样： field_name | count
___________________
field1 | 10
field2 | 20
field3 | 30
total | 60 我知道如何在SQL中实现它( UNION或ROLLUP)，尽管我找不到在M
浏览 13提问于2020-08-13得票数 3
回答已采纳
1回答
我有一个大型的MongoDb集合，用户可以在其中搜索多个数组字段。怎样才是最好的索引方法呢？我看到为多个Array索引创建索引的结果是：
"Mongo::Error::OperationFailure:不能索引并行数组“”
示例查询：
db.collection.find(
{category_ids: {$in: [object_id, object_id]},
second_category_ids: $in: {[object_id, object_id]}
}
)
浏览 3提问于2017-04-10得票数 0
我使用apache进行基于字段的搜索和全文搜索。我应该用Solr索引mongodb的整个集合吗？
如果我决定只对apache中的mongo集合文档中的选定字段进行索引，那么我能够从索引搜索查询中获得完整的文档吗？
浏览 0提问于2018-05-24得票数 0
回答已采纳
这听起来很奇怪，我希望我做错了什么，但是我的MongoDB集合正在以我的集合中的一个返回Count。
我收集了359671份文件。但是，count()命令返回359670个文档。
我正在使用mongo执行count()命令：
rs0:PRIMARY> db.COLLECTION.count()
359670
这是不正确的.
它没有在我的收藏中找到每一份文件。
如果我提供以下查询来计数，就会得到正确的结果：
rs0:PRIMARY> db.COLLECTION.count({_id: {$exists: true}})
359671
我相信这是WiredTiger中的一个bug。据我
浏览 6提问于2015-06-08得票数 14
1回答
有没有办法保证MongoDB的字段是唯一的(自动递增整数)？我知道你能做到：
{ $inc : { field : value } }
但是如果两个查询同时命中呢？MySQL会插入一个，然后插入另一个，这两个整数都是唯一的，但我不知道Mongo是否真的这样做了。
为了澄清，我知道这不是理想的方法，但这是一个临时实现，直到数据完成从MySQL的迁移(用户启动)。
浏览 5提问于2011-12-12得票数 3
回答已采纳
我正在尝试弄清楚我想要做的事情在Mongodb中是否可行。我乐于接受各种关于实现我所需要的更合适的方法的建议。
目前，我有两个集合：
车辆(包含车辆数据，如制造商和型号。这些数据可能是高度非结构化的，这就是我求助于Mongodb的原因。)
视图(仅包含IP、查看车辆的日期/时间和vehicle_id。可能有数以千计的视图)
我需要返回一个在2个日期之间有视图的车辆列表。该列表应包括视图数量。我需要能够排序的视图数量除了任何常见的车辆字段。因此，需要明确的是，如果一辆车有1000次查看，但在给定日期之间只有500次，则计数应返回500。
我非常确定我可以在MySQL中执行这个查询而不会有任何问题
浏览 0提问于2017-10-18得票数 0
参考下面的示例，它用于查询有限大小的文档，
run () ->
application:start (mongodb),
{ok, Conn} = mongo:connect (localhost),
{ok, Docs} = mongo:do (safe, master, Conn, test, fun() ->
mongo:delete (foo, {}),
mongo:insert_all (foo, [{x,1}, {x,2}, {x,3}, {x,0}, {x,-1}]),
Cur = mongo:find (foo, {'$query&#
浏览 2提问于2012-12-18得票数 0
我正试图为mapReduce编写一个MongoDb函数，并且在试图从reduce函数中的第二个MongoDb数据库查询数据时遇到了问题。下面是代码的一个示例：
var reduceUsers = function(key, values) {
var reducedUser = {
uid: key,
count: 0,
extractBytes: 0
};
var secondDb = db.getSiblingDB("second");
....
}
当我尝试运行mapReduce时，会得到以
浏览 3提问于2015-09-04得票数 0
回答已采纳
当使用具有多个索引数组字段值的MongoDB时，对$in的缓慢查询。
1)数组中有1个元素的查询速度快(< 15 ms)
db.collection.count ( { tag : { $in : [ 1 ] } })
我重复了对"tag“的所有值的查询，并且所有查询都是快速的。
i = 1; while (i < 1000) {
db.collection.count( { tag : { $in : [ i ] } });
i++;
}
2)具有2个或多个元素的查询速度慢(>1m50)
db.collection.count ( { tag : { $in
浏览 2提问于2015-11-18得票数 1
我正在使用spring mongo模板在mongodb上运行一个同意查询。我想知道有没有办法知道spring mongo模板中聚合结果的计数？
下面是我的聚合示例：
Aggregation agg = newAggregation(Class1.class,
match(criteria),
group("prop1", "prop2")
.avg("x").as("averageX")
);
我只需要知道如何在spring mongo模板中获
浏览 2提问于2015-09-25得票数 5
我使用django-nonrel与mongodb引擎相结合。如果在模型上也定义了存储在mongodb对象中的所有字段，那么它的工作非常完美。
但是我有一些关于mongodb对象的额外数据，这些数据不是在模型上设置的。这就是我的问题。现在，我执行一个额外的查询来获取原始mongodb对象，如下所示：
collection = connection.get_collection(self._meta.db_table)
self._mongo_data = collection.find_one({'_id': ObjectId(self.pk)})
它运行得很好，但效率不高，因
浏览 1提问于2012-03-12得票数 1
可以在NodeJS控制器中查找Mongoose模型中字段的数据类型吗？ 我正在Node12和Mongoos5中构建一个Mongoose。 我正在使用mongoose- pagination -v2插件构建分页。 我想动态生成Mongodb查询操作符。我遇到的问题是，在动态创建Mongodb查询操作符之前，我需要知道要过滤的字段的数据类型。我希望能够检查model字段的数据类型，以应用正确类型的Mongo查询操作。 否则，我对数据类型应用了不正确的操作类型。例如CastError: Cast to Can't use $options with Number 我想要做什么的示例伪代码：
浏览 20提问于2019-06-13得票数 0
回答已采纳
在MongoDB中，
要查询包含某些字段的记录，您可以执行以下操作：
collection.find({'field_name1': {'$exists': true}})
这将返回任何设置了'field_name1‘字段的记录...
但是如何查询mongo来查找只包含'field_name1‘(而不包含其他字段)的记录呢？我希望能够这样做，比如说，一个字段列表。
浏览 2提问于2012-11-02得票数 3
回答已采纳
我想知道你对以下情况的看法：
提供以下mongo db集合：
收藏大小:192.87
文档总数: 165.578.552
我想从现在起删除超过一年的文档。我估计这将是收藏的一半左右，大约8000万份文档。
所以基本上我有两个问题：
在删除文档之前运行count()查询以获得完全匹配的内容是否安全？
...->count({timestamp: {$lt: '1534976762'}})
注意：timestamp没有索引，我有另一个字段time，它是索引的，但是我还不能使用time.sec进行查询
第二，我可以一次安全地删除多少个文档？我来自MySQL world
浏览 0提问于2019-08-23得票数 2
我对MongoDB和Java非常陌生，我需要做一个非常简单的查询:获取插入到集合中的对象的最后一个文档。如果我使用mongo，我使用$last，然后将key value和时间戳字段放到最后一个文档中，但是使用java (3.0.4)，我没有找到关于last语句的任何信息
浏览 7提问于2015-10-05得票数 0
回答已采纳
1回答
MongoDB查询优化
、、、、
我希望从我的用户模型中检索如下所示的几个信息：
var userSchema = new mongoose.Schema({
email: { type: String, unique: true, lowercase: true },
password: String,
created_at: Date,
updated_at: Date,
genre : { type: String, enum: ['Teacher', 'Student', 'Guest'] },
role : { type: String, e
浏览 2提问于2015-01-08得票数 4
回答已采纳
2回答
因此，我试图设计一个简单的URL缩短应用程序，每次查询URL时，它都会更新它被查询的次数。
我正在考虑使用MongoDB，我正在考虑这样的样例模式
{
id : ...., //Mongo-generated ID
originalUrl: .... // The original URL
shortUrlKey: .... // The shortened URL key
createdAt: ....
updatedAt: .....
hitCount: ...... // Number of times the document has been queried.
}
我希望确保每次查询
浏览 0提问于2020-02-25得票数 -3
我正在使用Node、MongoDB和Mongoose构建一个应用程序接口。有一件事困扰着我，你似乎不能一次设置多个字段：
app.put('/record/:id', function(req, res) {
Record.findById(req.params.id, function(err, doc) {
if (!err) {
doc.update(req.params);
doc.save();
...
但是，您似乎必须计算出更新查询并在Model对象上运行它，而不是在document对象上运行它。除非您想要分配单个属性并在最后运行
浏览 0提问于2012-02-21得票数 12
connectFromField of $graphLookup被记录为接收数组：
字段名，其值$graphLookup用于递归匹配集合中其他文档的connectToField。如果该值是一个数组，则每个元素将在遍历过程中被单独跟踪。
但是，在每个版本的MongoDB上，我都尝试过--当提供了一个字符串数组时，它失败了：
Error:
Uncaught exception: Error: command failed: {
"ok" : 0,
"errmsg" : "expected string as argument for con
浏览 3提问于2020-11-18得票数 1
背景信息
我有一个PHP 7网络应用程序与一个Mongo 3.4.3后端。只是想看看如何最好地提供一个“快速搜索”字段，允许用户输入任何字符串，并让系统尝试搜索文档类型中的所有字段并返回匹配项。
文件如下所示：
{ "_id" : ObjectId("582f62aa6b6347a422abcc97"), "department" : "Accounting", "description" : "some test description", "phnum" : "+1999
浏览 3提问于2017-05-16得票数 0
1回答
我目前正在使用solr存储公开的推特信息。我有内容，情感，关键词，标签，语言，tweet_id等领域来捕捉推特的本质。我也在为相同的用例评估Mongodb。我正在尝试对mongodb和solr进行基准测试，它们都有、100万条记录。
我观察到，mongodb中的组查询比solr的facet查询慢2.5到3倍。
以下mongodb查询
db.tweets.aggregate(
[
{
$group : {
_id : "$sentiment",
total : { $sum : 1 }
}
}
]
)
需要481毫
浏览 5提问于2014-09-16得票数 0
我在使用Meteor和MongoDB一起使用这样的文档集合：
{a: 'a1',
b: 'b1',
c: {
d: 'd1',
e: 'e1'
}
}
我最初创建了一个这样的索引：collection._ensureIndex({'c.d': 1});
并运行这样的查询：collection.find({c: {d: 'd1'})。它们运行得非常慢，当我使用explain()进行调试时，我意识到它们没有使用索引。
OTOH，如果我运行这样的查询：collection.
浏览 4提问于2016-04-29得票数 2
回答已采纳
我正在尝试使用当前日期更新我的mongoDB集合中的生效日期。我要更新集合中生效日期为空的所有文档。
您如何配置转换器来执行此操作？查询引用字段信息消息涉及Id，而元素字段看起来需要一个有效负载，其中包含将替换正在更新的文档的有效负载。我只想更新一个字段，但当前查询出现错误，但它在mongoDB命令行上确实有效。
这是我想要实现的查询：
db.stores.update({"EffectiveEndDateTime" : null}, {$set : {"EffectiveEndDateTime" : "2017-01-13T18:56:55.257Z&
浏览 5提问于2017-01-14得票数 0
回答已采纳
1回答
在来自的以下代码中，创建了mongodb客户端(如下所示)：
import (
"context"
"time"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/readpref"
)
ctx, cancel := context.WithTimeout(context.Background(
浏览 9提问于2022-08-13得票数 0
回答已采纳
我正在尝试从命令提示符验证Mongo数据库，使用直接密码，它正在工作。但是根据MongoDB用户的文档，尝试使用passwordPrompt()。
将错误定义为js ReferenceError: passwordPrompt。目前正在尝试的版本是4.0.4。
db.auth("username",passwordPrompt())
未定义 E查询js ReferenceError: passwordPrompt：
提前谢谢！
浏览 1提问于2021-10-05得票数 0
我的MongoDB集合中的文档非常频繁地更改状态字段。我可以非常清楚地看到，使用mongoDB客户端(Robo 3T)。 现在我想使用mongo shell来监控这个过程： mongo --host=localhost db --eval "db.getCollection('events').find({status:'ACTIVE'}).count()" 这将返回一个正确的结果，但随后mongoDB会“缓存”该结果，并且在10秒内不会返回更新的结果。我需要每隔200毫秒更新一次。 来自Robo 3T的相同查询总是返回更新后的结果，以大约5m
浏览 21提问于2019-02-18得票数 0
回答已采纳
当我插入可序列化类答案的单个实例时，插入可以正常工作。当我尝试插入一系列答案时，我会得到一个异常。当然，我不需要将我的答案数组转换为一个BsonDocuments数组，对吗？(我不需要为了一次插入就这么做！)
/********* DOES NOT WORK - THROWS EXCEPTION *****************/
public bool addAnswers(AnswerDataModel[] answers)
{
bool returnval = true;
try
{
this.answ
浏览 4提问于2014-07-22得票数 1
回答已采纳
2回答
我的mongodb集合如下所示：
{
"_id" : ObjectId("5333bf6b2988dc2230c9c924"),
"name" : "Mongo2",
"notes" : [
{
"title" : "mongodb1",
"content" : "mongo content1"
浏览 11提问于2014-03-27得票数 1
回答已采纳
对于mongo查询，我仍然有点谦虚，是否有可能，或者--从性能上考虑--是否有必要将下面的MongoDB查询变成更智能的形式？$elemMatch的双重使用会影响性能吗？
例如，一个充满鸡舍的数据库：
{chickens: {$elemMatch: {recentlyDroppedEggs: {$elemMatch:{appearance:"red-blue-striped"}}}}}
因为所有鸡舍里都有一只鸡(在它的鸡阵列里)，它最近把一个红蓝条纹的鸡蛋扔进了它最近的dropped阵列中。
谢谢你的提示！
浏览 0提问于2013-11-05得票数 0
回答已采纳
我使用的是ubuntu操作系统上的mongoDB版本3.6.3。我已经创建了一个包含100条记录的集合 为了操作mongo shell上的数据，我将游标赋值如下 cur = db.dummyData.find({}, {_id: 0}) 现在cur.count()是100，但cur.toArray().length是80。 我不确定为什么会发生这种情况。我尝试过一堆不同的集合，toArray()的长度总是比实际计数小20。 如果能帮助理解这个行为，我将不胜感激。
浏览 29提问于2020-04-26得票数 0
在MongoDb中执行查询时，我需要获取所有匹配项的总数，以及作为有限/分页子集的文档本身。
我可以用两个查询来实现这个目标，但我不知道如何用一个查询来实现这一点。我希望有一个mongo特性，在某种意义上，它等同于SQL_CALC_FOUND_ROWS，因为必须运行两次查询似乎有点过分了。任何帮助都是最好的。谢谢!
编辑:下面是执行上述操作的Java代码。
DBCursor cursor = collection.find(searchQuery).limit(10);
System.out.println("total objects = " + curs
浏览 0提问于2012-06-05得票数 7
回答已采纳
我有一个MongoDB集合，它看起来与下面的文档相同，我只想找到一个字段值计数，它显示在嵌入式数组对象中。
我尝试在下面的查询中获取数据，但不起作用
db.mycollection.find({'quizzes':{skill:'html'}}).pretty()
下面是带有示例值的mongo文档结构。该结构与我的原始文档相同。
{
"user": "values",
"date": "234-234-234-234",
"quizzes":[
{
"
浏览 4提问于2019-08-28得票数 1
回答已采纳
1回答
我有一个mongoDB集合，每天有4200万个寄存器和100万个新寄存器。
我们发现mongoDB查询的性能很低。在mongostat中显示字段:qr、qw、ar、aw，其值为300-500。
第一步是检查索引并为可能花了这么长时间的查询创建新的索引。
现在我们大部分时间都有很好的表现。
但是在某些情况下(随机时间)，我们得到了很多挂起状态的连接，所有的查询速度都很慢。
但是，top命令在处理速度和ram方面显示了良好的性能。
问题是：
如何进一步检查哪些不是优化的查询。
在新的文物显示中，插入命令在这个特定的集合中占据了62%的“最耗时”，有什么方法可以加速吗？
为什么会出现挂起的连接呢？奇
浏览 0提问于2012-07-17得票数 4
回答已采纳
3回答
我刚接触过MongoDB/Mongoose，并使用一个非常大的数据库( 25000多个文档)。我需要配置不同的查询: by字段，前10个文档，一个id。问题在于性能-服务器响应太慢(大约10-15秒)。请告诉我如何配置这样的服务器响应是快速的？它只依赖于架构设置，还是也可以依赖于其他事情，例如数据库连接参数或查询参数？查询应按“地区”和“地点”进行。谢谢你的帮助！
下面是模式：
const mongoose = require('mongoose');
const Schema = mongoose.Schema;
const houseSchema = new Schem
浏览 4提问于2020-03-13得票数 4
回答已采纳
当我从命令行使用mongo命令连接到MongoDB时，我需要发出一个use <db>命令来切换到适当的数据库，然后才能运行查询，如下所示：
[mongo@mongotest ~] $ mongo localhost:10001
MongoDB shell version: 2.4.6
connecting to: localhost:10001/test
> use mydb01
switched to db mydb01
现在我可以运行我的查询：
> db.records.find({"contact.name": "Jack"});
浏览 2提问于2014-08-07得票数 1
我正在努力实现一些已经证明在MongoDB中相当困难的东西。
我有两个收藏品。一种称为“标记”，另一种称为“路由”，并保存用户在标记之间创建的路由。路由集合有两个重要的字段: start_marker和end_marker。这些字段是标记集合中标记的_ids。
在浏览地图时，应用程序对标记集合进行地理空间框查询，以在地图上查找和显示标记。
当用户单击标记时，一个气泡会显示标记名。
在名称下面还有一个动态字段，我有问题。这个字段应该显示：
从地图上选定的标记中驱动哪些标记
有多少次这些标记被驱动到
在动态字段中，只有3个最常见的标记会被显示出来。
因为我的记录集合记录了sta
浏览 5提问于2013-01-31得票数 0
回答已采纳
1回答
我正在使用rmongodb在R中运行mongodb查询。我需要找出文档中是否存在某些字段。然而，$exists不会产生任何结果。下面是用于查询的示例代码。
library(rmongodb)
> mongo <- mongo.create(host="localhost")
> dbns <- mongo.get.database.collections(mongo, db="namedisambiguation")
> buf <- mongo.bson.buffer.create()
> mongo.bson.bu
浏览 2提问于2014-01-27得票数 1
回答已采纳
1回答
我想在MongoDB中使用C#中的Linq随机获取一张记录。这就是我在做的事。
public string RandomWord()
{
using (Mongo mongo = new Mongo(_mongoConfig.BuildConfiguration()))
{
try
{
mongo.Connect();
var db = mongo.GetDatabase(_dbName);
IMongoCollection<dic_words> collecti
浏览 0提问于2012-06-03得票数 0
我有一个FastAPI Python应用程序，它具有在MongoDB实例上运行的路由。连接工作正常，我可以查询文档中的GET端点，但是在FastAPI内部创建一个新文档似乎是不可能的。
我一直得到：
您还没有定义默认连接
我有一个独立的脚本来处理一些数据迁移任务，它使用与FastAPI应用程序完全相同的DB类和文档模型，并且该脚本能够将文档保存得非常好。在API和脚本之间如何实例化DB对象没有区别。
DB类：
from os import getenv
from mongoengine import connect
from pymongo import MongoClient
from
浏览 16提问于2022-03-09得票数 0
回答已采纳
1回答
我是mongoDB的新手，目前我们正在尝试迁移以前的驱动程序
在我们的旧代码中，我们使用了全局签名mgo驱动程序中的以下内容
//where apps is a struct
apps := []model.App{}
err = mgo.Collection.Find(query).Skip(skipCount).Limit(MaxResults).Sort("-starttime").All(&apps)
因此，对于新的芒果车手，我尝试了如下使用Find，但这是行不通的。
// Set FindOneOptions
findOpt := option
浏览 13提问于2022-10-31得票数 1
回答已采纳
我的团队现在开始使用MongoDB，并希望将一些sql迁移到Mongo。例如，我有一个订单表，其中包含字段price和quanty。我想查询大于100的价格*quanty。sql如下所示
select * from Order where price * quanty > 100;
如何在Mongo中使用“价格*数量”这种查询？
谢谢。
浏览 0提问于2019-09-17得票数 1
我有一个mongodb查询，我想添加一个计算字段。计算字段基于项目在另一个查询结果中的位置。因此，我的查询返回列a、b、c、d，然后列e应该基于当前行是否与另一个查询匹配。
在mongo中有没有一种有效的方法来做到这一点？我真的不知道该怎么做...
浏览 2提问于2013-01-14得票数 0
回答已采纳
1回答
{
"sections": [
{
"desc": "no flow ID",
"sectionObj": [
{
"smartFlowIdList": []
}
]
},
{
"desc": "has flow ID",
浏览 6提问于2022-11-06得票数 1
1回答
当我必须返回一个字段名时，为什么它会说“没有为类型'Map<String，dynamic>‘定义获取方法' fieldname’”。
import 'package:mongo_dart/mongo_dart.dart';
var db = Db("mongodb://127.0.0.1:27017/test");
await db.open();
var collection = db.collection('Users');
await collection.find().forEach(
浏览 7提问于2021-03-05得票数 0
当查询两个字段时，假设它们不是复合索引的一部分，会发生什么情况，例如：
db.collection.ensureIndex( { a: 1 } )
db.collection.ensureIndex( { b: 1 } )
db.collection.find( { a: 2, b: 2 } )
我想知道是否会扫描多个文档，或者Mongo DB是否不扫描任何内容而explain()将返回：
indexOnly: YES
浏览 3提问于2013-01-13得票数 0
回答已采纳
这是我第一次接触mongodb，我正在用MONGODB数据库编写PHP7，不知道该怎么查询。
我的查询在mongo上运行：
db.points.find(
{ coordenadas:
{ $geoWithin:
{ $centerSphere:
[ [ -23.010382,-43.476006 ] , 10 / 3963.2 ]
}
}
}
)
但我不知道如何在PHP上编码：...
try {
$mongo = new MongoDB\D
浏览 0提问于2019-01-10得票数 0
我的go代码是这样连接到MongoDB的：
uri := "mongodb://localhost:27017"
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
client, err := mongo.Connect(ctx, options.Client().ApplyUIR(uri))
if err != nil {
panic(err)
}
我想创建几个goroutine来定期查询数据库，并且不确定让每个goroutine都使用
浏览 0提问于2021-02-25得票数 1
我正在使用spark mongo连接器()。如果我使用的read config设置在not上是正确的，我需要验证几件事。我使用的是读配置
val courseReadConfig = ReadConfig(Map(
"uri" -> "mongodb://ip:port/db.collection?read_preference=Primary([{\"cloudType\" : \"aws\",\"dataCenter\" : \"us-east-1\"}])",
"part
浏览 0提问于2016-12-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
