草庐IT

language-scala

全部标签

scala - 在 Play 中排队异步任务! - 正确的方式

我有一个小游戏!application(2.1,scala)充当Java库的RESTful前端。此Web应用程序使用以下方式对后台处理任务进行排队:Akka.system.scheduler.scheduleOnce(Duration(0,SECONDS)){newTaskWorker().run(batchId)}在TasksController中。目标是立即开始由Java库进行繁重的处理,但在后台进行。Scala2.10及其futuresandpromises的出现,重构队列以利用这个新API是否更有意义?总的来说,我正在寻找一种能够执行后台处理的方法,目前由Resque实现。Ru

scala - 我需要一个 Scala 中的客户端库用于 Redis 集群

我已经在启用集群模式的AmazonEleasticache中创建了一个redis。我有一个scala的客户端(scala-redis)但是这个客户端在正常模式下工作正常(集群禁用模式)但在集群模式下不工作。我收到MOVED12351127.0.0.1:7000的错误。我搜索了很多客户端但是我找不到一个支持集群模式的。所以请帮我解决这个问题。 最佳答案 https://github.com/etaty/rediscala相当活跃,似乎支持集群模式。 关于scala-我需要一个Scala中的

mongodb - 用另一个列表(MongoDB 或 Scala)替换模型子列表

我的文档结构如下:{"name":"CategoryChildLevel2","parentId":"2","otherAttribute":"anyVal","breadcrumb":[{"name":"RootCategory","id":"1"},{"name":"CategoryChildLevel1","id":"2"},{"name":"CategoryChildLevel2","id":"3"}]}我想要的是能够运行这样的查询:替换以开头的面包屑数组{"name":"RootCategory","id":"1"},{"name":"CategoryChildLevel1"

mongodb - Scala Play Salat 聚合示例

我在后端使用带有MongoDB的ScalaPlay2.x,我必须承认Salat对mongoCRUD操作有很好的支持。但到目前为止,我还没有找到任何好的示例来说明如何使用$unwind、$match、$group或聚合管道等SALAT调用mongo聚合函数。例如db.posts.aggregate([{$unwind:"$tag"},{$group:{_id:"$tags",count:{$sum:1}}},{$sort:{$post:-1}},{$limit:1}])UPDATE(ALTERNATIVE)我没有找到任何系统地解释用法的帮助SALAT中的聚合查询。因此,作为解决方法,我还

mongodb - 将 mongodb 聚合函数转换为 ReactiveMongo 和 scala

我正在尝试在ReactiveMongo中实现一个聚合方法,但我有点卡住了。我有以下数据集:{"_id":ObjectId("522891aa40ef0b5d11cb9232"),"created":1378390442167,"origin":2,"originIpAddress":"","rating":3,"remindersSent":1,"status":4,"text":"","updated":1378563426223,"userInfo":{"firstName":"Person","lastName":"Person","email":"person@person.c

【论文阅读】InstructGPT: Training language models to follow instructions with human feedback

论文链接:InstructGPT1.摘要把语言模型变大并不意味着会让模型更好的理解用户意图,例如大的语言模型会生成一些不真实、有害的、没有帮助的输出给用户,换句话说,这些模型并没有和用户的意图对齐(aligned)。在这篇论文中我们展示了通过使用用户反馈来微调模型的方法,从而使得语言模型在一系列任务上与用户意图对齐。首先通过人工撰写和OpenAIAPI两种方式收集问题(prompts),然后人工来写这些问题的答案,从而构建成一个数据集,再使用这些数据集对GPT3进行有监督的微调;我们又通过对模型的输出进行(人工)排序构建一个数据集,在这个数据集上,我们从人类反馈中通过强化学习进一步微调这个有监

mongodb - 通过 Scala Play 连接时如何解决 MongoDB 超时错误!框架?

我正在使用ScalaPlay连接到MongoDB!框架。我最终收到此超时错误:!@6j672dke5-Internalservererror,for(GET)[/accounts]->play.api.Application$$anon$1:Executionexception[[MongoTimeoutException:Timedoutwhilewaitingtoconnectafter10000ms]]atplay.api.Application$class.handleError(Application.scala:293)~[play_2.10-2.2.1.jar:2.2.1

java - 非阻塞异步 mongo java/scala 驱动程序可以阻塞线程——如何处理?

使用非阻塞异步mongojava/scala驱动程序,可以为无法通过空闲连接直接执行的操作定义等待时间和等待队列大小。设置这些值时,mongo驱动程序将使线程等待可用连接。对于使用非阻塞异步IO编写的应用程序来说,这种行为是非常危险的。这些应用程序使用非常有限的线程数(=内核数)。阻塞其中一个线程会阻塞整个应用程序。对于这种应用程序,推荐的方法是什么?我们是否应该将所有这些等待设置设置为0并在应用程序中重试处理MongoWaitQueueFullException?当连接空闲时,驱动程序是否应该调用应用程序回调?预先感谢您的回答! 最佳答案

json - 使用 Scala 从 mongodb 访问值

执行MongoDB查询后,我的结果类型为:res=Seq[Document]要访问BsonString,我使用:res(0).get("n"))返回:Some(BsonString{value='value'})如何从BsonString中以字符串形式访问值value?访问Some(BsonString{value='value'})的值返回BsonString{value='value'}doIneedtoconvertBsonString{value='value'}使用库(例如Jackson)到Scala对象,然后访问值? 最佳答案

mongodb - mongo scala驱动程序在使用insertOne后得到_id

希望在使用insertOne时得到刚才插入的文件ObjectId。根据我的考虑,一种方法是在客户端生成_id,另一种方法是通过文档的指定字段进行查询。哪种方法更好或有其他方法?ps:我知道mongo中的ObjectId是用机器和时间信息生成的。总之,我只是想知道mongoObjectIdshouldgenerateonclientormongodserver是什么意思? 最佳答案 正如MongoDB文档所指定的,如果您使用可变文档,如果您没有提供由MongoDB自动创建的带有_id的文档,您应该取回该文档。InsertMongoDB