jjzjj

观看mongo oplog的scala脚本

我需要在生产中复制一个mongo数据库以切片到另一个研究数据库,但我不能使用副本集或任何类似的东西,因为这些生产切片无法停止或重新启动。我现在唯一的选择是编写一个scala脚本,该脚本将在生产切片上运行并观察mongo的oplog集合,并且对于oplog上的每个新写入,它必须将其发送到另一个研究数据库并复制操作那里。作为scala和mongo的新手,如果有人能给我一些指导,告诉我如何开始这样的事情,以及这是否是正确的做法,或者是否有其他方法可以做到这一点,我会很高兴。我的领导坚持这样的事情,所以如果有人能指出我必须寻找的库以及脚本应该如何的正确方向,那就更好了。任何帮助对我来说都是非常

scala - 错误 : class file needed by ValidDateOrNumericTypeHolder, 需要 RegisterJodaTimeConversionHelpers() - 它没有希望,我找不到导入

也许我是瞎子之类的,但我找不到我需要的导入。我在玩scala+mongodb。一切都很好,我只是这个JodaTimer有一些问题。Inthistutorial你必须像这样导入它:importcom.mongodb.casbah.conversions.scala._RegisterJodaTimeConversionHelpers()好吧,我找不到它。我只有:importcom.mongodb.casbah.commons._importcom.mongodb.casbah.util._importcom.mongodb.casbah.query._//...嗯,没有“转换”。还有另一

scala - NoClassDefFoundError => 使用 Play 开始时的 ClassPath$JavaContext

我做了一个小的Scala,Play2.0.2应用程序。当我使用playrun命令时它工作正常,但是当我使用playstart或playcleancompilestage+target/start时,当尝试使用Casbah/Salat进行MongoDB插入时,我得到以下堆栈:[info]application-Can'tcreateuserjava.lang.NoClassDefFoundError:scala/tools/nsc/util/ClassPath$JavaContextatscala.tools.scalap.scalax.rules.scalasig.ScalaSigPa

json - 使用 Casbah/Salat 到 Json 的单个序列化层

我正在尝试创建一个序列化层,它允许我:将我的类存储在MongoDB数据源中将它们转换为JSON以在RESTAPI中使用它们。有些类显然不是案例类(因为它们是从Java代码库继承的),我将不得不为此编写临时代码。为我的非标准类型注册BSONHook是否是正确的方法,它是否提供Json序列化? 最佳答案 Salat维护者在这里。您可能更愿意创建一个Salat自定义转换器,而不是向Casbah注册一个BSON钩子(Hook)。参见simpleexample和spec.如果您遇到任何问题,请随时pingmailinglist使用一个小示例G

mongodb - 如何做 casbah 批量插入

在casbah中,我看到在MongoCollection上定义了以下函数:definsert[A](docs:A*)(implicitdbObjView:(A)⇒commons.TypeImports.DBObject,concern:mongodb.WriteConcern=writeConcern,encoder:TypeImports.DBEncoder=...):TypeImports.WriteResult如果我没理解错的话,您可以将多个DBObject传递给此函数以进行批量插入。我的顾虑/问题是这是一个参数列表。如果我有一个巨大的批量插入(比如几百个)怎么办?可以通过这种方

mongodb - 为什么多个 mongodb 连接与 Casbah?

我必须使用casbahscala客户端管理与MongoDb的多个数据库连接。我有一个可行的近似值但会打开数百个连接。我想保存一个Map[String,MongoDB],它为每个数据库保存一个连接(这是关键。我在SparkStreaming中使用它和一个双节点集群,所以我认为这是一个序列化问题,但我不知道如何解决。看看我的课。abstractclassAbstractMongoDAO(@transientvalconfig:Config)extendsCloseablewithSerializable{@transientprivatevalmongoConfig=config.getC

mongodb - Scala:在 MongoDB 中使用 Casbah 写入/更新/删除对象的示例?

在Casbah教程(http://mongodb.github.com/casbah/tutorial.html)中找不到任何关于如何在MongoDB中写入/更新/删除对象的说明。请帮助示例或告诉要查找这些方法的类。谢谢! 最佳答案 更新的答案在提出并回答了这个问题几个月后,Casbah文档已更新以包含DoingCRUDoperations部分。也许这个问题/答案有助于实现这一目标。或者也许有人意识到不在数据库教程中记录CRUD操作是克雷克雷。原始答案为了理解为什么Cashbah教程没有提供如何在MongoDB数据库中插入、更新或删

mongodb - 以编程方式防止默认创建 MongoDB 数据库

有没有一种方法可以通过JavaAPI检查Mongo数据库是否存在,而无需在启动调用时创建数据库?我目前正在使用Casbah(Scala驱动程序)与我们的Mongo实例进行交互valmongo=MongoConnection(List(newServerAddress("localhost",27017)))valdb=mongo.getDB("testXXX")APIgetDB似乎默认创建一个数据库,我不希望这种情况发生如果testXXX不存在,我不希望Mongo创建数据库,而是让我作为消费者决定它是否存在是否有通过MongoDBjava驱动程序或Casbah提供的API?

添加 casbah 时 Maven 抛出错误

我已将casbah添加到我的依赖项中使用com.mongodb.casbahcasbah_2.8.02.1.5.0然后我就写了一个简单的mongo连接语句valmongoConn=MongoConnection()valmongoDB=mongoConn("test")valnewObj=MongoDBObject("foo"->"bar","x"->"y","pie"->3.14,"spam"->"eggs")然后我编译了mvncompile但是它抛出找不到目标的错误[ERROR]Failedtoexecutegoalonprojecttest-project:Couldnotres

scala - 如何通过 Casbah 将带有列表的 Scala 对象转换为 MongoDBObject

我正在通过编写一个简单的应用程序来学习MongoDB和Casbah。当我尝试将具有列表成员的对象转换为MongoDB对象时卡住了。这是我的课caseclassBorrowerRecord(name:String,checkedOut:List[BookTag]){require(!name.isEmpty)require(!checkedOut.isEmpty)}caseclassBookTag(subject:Subject,bookName:String){require(!bookName.isEmpty)}caseclassSubject(name:String,categor