1回答
我是akka stream的GraphDSL新手。我正在为我们已经有的测试框架做DSL，到目前为止还不错，但我面临的问题是，当人们使用DSL时，我不能有一条新的线。使用构建器，我创建了一个解决方案，但我不认为它真的很好
import GraphDSL.Implicits._val runnableGraph = RunnableGraph.fromGraph(GraphDSL.create() { implicit
浏览 5提问于2017-07-05得票数 0
回答已采纳
1回答
自定义Akka流
、、
我使用自定义流阶段成功地做到了这一点，在抓取(In)元素上，我推送(out，(elem，StreamMetaData))。实际上，它不是“转换”现有的源，而是将其传递给流以重新创建新的源。现在，我正在尝试实现以下MetaStream阶段：因此，在源产生(A，StreamMetaData)元组的情况下，我希望将A传递给一个现有的流，以便进行某些计算，然后将产生的输出'B‘与StreamMetaDataUniformFanOut和UniformFanIn使用Unzip(A StreamMetaData，A
浏览 2提问于2018-06-15得票数 1
回答已采纳
我很难将Scala中的implicit应用到Akka中。根据，Scala中implicit类的基本概念是为5 times prinln("foo")创建一个IntWithTimes对象，通过导入Helpers._使times方法隐式可用。() { import GraphDSL.Implicits._
val in = Source通过将Builder传
浏览 2提问于2016-12-02得票数 0
回答已采纳
val graph = RunnableGraph.fromGraph( ((source, sink) => Seq$Builder.addEdge(Graph.scala:1567)[info] at akka.stream.scaladsl.GraphDSL</em
浏览 11提问于2021-01-06得票数 1
回答已采纳
我找不到新构建的spring云网关的适当文档。你能给我指一下入门指南吗？我期待着在Akka中构建类似GraphDSL的东西。谢谢
浏览 3提问于2017-09-21得票数 0
回答已采纳
这是一个使用GraphDSL应用编程接口的非常简单的新手问题。intDoublerFlow = Flow.fromFunction[Int, Int](i => i * 2) import GraphDSL.Implicits._
/
浏览 2提问于2017-02-24得票数 5
回答已采纳
{GraphDSL, RunnableGraph, Sink, Source}
val graph = GraphDSL.create() {rg = RunnableGraph.fromGraph(graph)}
问题是，在</e
浏览 0提问于2016-05-12得票数 2
回答已采纳
1回答
对我来说，最简单的方法是从文件中读取流行，处理它并提供给目标服务。OneForOneStrategy, SupervisorStrategyimport akka.stream.scaladsl.{ Flow, GraphDSLdown the stream to 1 element per second. .fromGraph(GraphDSL.create() {
浏览 3提问于2019-09-23得票数 0
我希望保留辅助Sink的物化值，以便能够在启动构造的流时对其值进行操作。Incoming] GraphDSL.create() { implicit b => val bcast
浏览 2提问于2016-10-21得票数 8
回答已采纳
1回答
我的目标是重新格式化我未来的响应并将其保存到一个文件中。这个流程可以概括如下： import GraphDSL.Implicits._
浏览 0提问于2017-02-06得票数 10
回答已采纳
1回答
我想在Akka中创建一个带有Broadcast和Concat的图形，但是下面的代码不起作用。我想知道为什么不起作用。val src = Source(1 to 3) RunnableGraph.fromGraph(GraphDSL.create() { implicit b => val bcast = b.add(Broadcast[Int](2))
val co
浏览 1提问于2016-03-15得票数 0
回答已采纳
1回答
我想在akka streams中创建一个由许多操作组成的接收器。例如，映射，过滤，折叠，然后下沉。目前我能做的最好的事情是。我不喜欢它，因为我必须指定广播，即使我只允许一个值通过。def kafkaSink(): Sink[PartialBatchProcessedResult, NotUsed] = { import GraphDSL.Implicits._
val broadcast = b.a
浏览 5提问于2018-12-31得票数 0
回答已采纳
我们想要并行化我们的流的一部分，像mapAsync一样保持排序，但是没有未来。def flatMapConcatParallel[In, Out](parallelism: Int)(f: In => Source[Out, _])(implicit mat: Materializer): Flow[In, Out, NotUsed] = {
// TODO there should be a better way to add parallelism that avoids a run
浏览 0提问于2017-10-27得票数 0
我在研究阿克卡流。当我在阿克卡读一个关于平衡的例子时。 import GraphDSL.Implicits._
val
浏览 1提问于2018-12-31得票数 1
回答已采纳
1回答
val bottomHeadSink = Sink.head[Int] (topHS, bottomHS) =>
import GraphDSL.Implicits我可以在没有builder.add的情况下在图形之外创建一个广
浏览 0提问于2018-02-06得票数 2
回答已采纳
1回答
在inflateFlow阶段，我检查是否已经在DB中处理了请求。GraphDSL.create() { implicit builder: GraphDSL.Builder[NotUsed] =>
val
浏览 0提问于2017-11-09得票数 1
回答已采纳
1回答
: Sink[Int, Future[Done]] = Sink.foreach[Int](x => println(x)) import GraphDSL.Implicits._ ClosedShape但是，我需要扫描输出，看看哪一行没有被处理。有没有办法打印/记录失败的<em
浏览 3提问于2017-09-21得票数 2
回答已采纳
1回答
我使用图形dsl根据我看到的一些示例代码创建了一些流处理作业。mapAsync(2)(x => boolChecker(x).toMat(mySink)(Keep.right)
GraphDSL.create(lastly) { implicit builder => import GraphDSL.Implicits._
val broadcast1 = builder.add~> broa
浏览 3提问于2016-02-29得票数 2
回答已采纳
1回答
具体到MongoDB集合中。Mongo提供一个Sink，将其写入指定的集合中。val sink: Sink[Document, Future[Done]] = MongoSink.insertOne(collection(id))
问题是，在连接时，我需要指定接收器，但是每个元素都定义它应该进入哪个接收器是否有一种在元素到达时动态使用特定接收器的方法。或者这是不可能的，例如，我应该为每个id使用不同的Kafka主题，并将每个源连接到单独的接收器上？
浏览 7提问于2022-01-05得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
