akka-stream

0热度

2回答

我已经开始使用Akka Streams和Op-Rabbit，并且有点困惑。我需要根据谓词拆分流，然后将它们组合起来，就像我在创建图形和使用分区和合并时完成的一样。我已经能够做这样的事情使用GraphDSL.Builder，但似乎无法得到它与AckedSource /流程/水槽工作图形看起来像： | --> flow1 --> | source--> partition --> |

3热度

3回答

在AKKA-Streams中使用动态水槽目的地？

我对AKKA比较陌生，所以想要学习基础知识。我的用例是不断从JMS队列读取消息并将每个消息输出到新文件。我已经得到了基本设置与工作： Source<String, NotUsed> jmsSource = JmsSource .textSource(JmsSourceSettings .create(connectionFactory) .withQueue("myQue

0热度

1回答

交替，以减少发送实时统计数据（的减少）

我有一个愚蠢的问题，但不可能不知道的原因： import akka.{Done, NotUsed} import akka.actor.Status.Success import akka.actor.{ActorRef, ActorSystem} import akka.stream.scaladsl.{Flow, RunnableGraph, Sink, Source} import

0热度

1回答

优化复杂查询（使用分页）

假设某些数据库（PostgreSQL）中有N表。每个表Ti包含字段(time, label)，其中time是某个数字（例如长timestamp）。 label是一些文字。有N条件。每个条件Ci适用于特定表Ti。每个条件可能很复杂（使用自己的子查询，也可以加入）。我需要从条件中收集所有表格T的记录并获得排序结果的页面。该任务由SQL和UNION ALL解决。下面的伪说明了在抓取了一些网页： (S

2热度

3回答

SHA256的数据流

我有一个用例，我正在使用GET请求从URL下载文件。是否有可能计算文件流的SHA256而不保存到磁盘或将整个对象保存在内存中？

1热度

1回答

如何在Akka Streams中使用集合作为源？

我是使用Akka Streams API的新手。我正在尝试创建自定义图形阶段。对于我的每个阶段，我希望每个“元素”都是一个scala集合，例如整数向量。但是，当我使用Source（Vector（1,2,3））或沿着这些行时，它会单独传递元素1,2,3。有没有一种方法可以在整个矢量中传递，因为阶段的结果取决于矢量内项目之间的关系？目前我使用List作为“包装”，但我不喜欢这种解决方案。提前致谢。示

2热度

1回答

卡夫卡主题websocket

我想实现一个安装程序，我有多个Web浏览器打开一个websocket连接到我的akka-http服务器，以便读取发布到卡夫卡主题的所有消息。所以消息流应该走这条路 kafka topic -> akka-http -> websocket connection 1 -> websocket connection 2 -> websocket conne

1热度

1回答

Akka流mapConcat不能与循环运行RunnableGraph

我有RunnableGraph像下面。当broadcast和merge阶段之间有简单的map时，一切都很好。但是，当涉及到mapConcat时，此代码在使用第一个元素后不起作用。我想知道为什么它不起作用。 RunnableGraph.fromGraph(GraphDSL.create() { implicit b => import GraphDSL.Implicits._ val M =

0热度

2回答

Kafka - scala - 处理多个邮件

是否可以通过Kafka Producer对象发送字符串数组。我想从'topic1'中接收一些消息 - 文本行然后将其分割为单个单词并将其发送到另一个主题。 object KafkaConsumer extends App { implicit val actorSystem = ActorSystem("test-actor-system") implicit val s

0热度

1回答

停止Akka演员在WebSocket断开连接或空闲时间后

我目前正在使用Akka actors，streaming和http的组合来处理客户端告诉服务器想要接收事件的速度有多快，并且服务器发送客户端事件的速度。这里的客户端消息到服务器： { "uuid": "d30711c6-6bbf-4f11-9471-638ef7e19dfd", "startTime": "1501254050", "rate": "1.5" } 这是由看起来像这样一