我当前的代码有签名：(它简单地委托给akka-http客户端)def putObject(key: String, contentType: ContentType): Sink[ByteString,Future[HttpReponse]]
如何创建一个接收器，该接收器</em
浏览 0提问于2017-07-11得票数 1
我是第一次接触卡夫卡的世界。我们计划设置Kafka来满足我们的数据流需求。在我们的例子中，接收器是REST端点。支持Kafka => REST端点连接的连接器有哪些？这类似于AWS简单队列或主题的工作方式。
浏览 1提问于2017-06-09得票数 0
akka http网络套接字运行得很好。它接受一个Flow[Message, Message, Future[Done]
我们可以创建一个同样形状的Source val src = Source.maybe和Sink val snk = Sink.foreachsrc用于将数据发送到websocket(流的源)，snk用于接收数据。在某些情况下，我们希望扩展所传递的流，例如，我们希望接收消息，将其发送到</e
浏览 1提问于2018-02-02得票数 0
回答已采纳
1回答
我们可以像ESB4.9那样将数据从WSO2 ESB4.8.1发布到WSO2 DAS吗？在wso2 ESB4.8.1中是否有创建事件接收器的方法或解决方法？
浏览 4提问于2015-12-23得票数 1
2回答
我有一个关于使用Akka Streams和Akka集群的问题。我正在尝试做一个使用Akka Streams和Akka Cluster的分布式字数统计版本。我想构建一个Akka Streams客户端，它将文本文件作为流I/O读取，并将单词流发送到远程集群。这是客户端的代码：
final Path file = Paths.get("example.txt"
浏览 5提问于2018-11-10得票数 2
目标是实现一个具有此签名的函数。返回的源发出接收器接收到的任何信息。；rightReceiver和rightEmitter是右端点处理程序流的进进出出。例如：import akka.http.scaladsl.model.ws.Message
import
浏览 4提问于2016-09-21得票数 2
回答已采纳
1回答
我有一个公开REST端点的服务，经过几次转换后，它也通过它的REST端点调用第三方服务。
我想在我的服务上实现某种节流，以避免被这个第三方服务节流。请注意，我的服务的端点只接受一个请求，而不是它们的列表。我正在使用Play，我们也有Akka Streams作为依赖项。我的第一个想法是让我的服务将请求保存到数据库表中，然后有一个<
浏览 1提问于2018-11-08得票数 1
1回答
Akka Http请求和响应模式
、、、、
我有一个需求，客户端调用通过akka http创建的post端点。一旦请求在post方法中，我就需要将post对象传递给流(由源、多个流和接收器等组成)，并从接收器获取响应，以便可以将响应返回给客户端。我只想物化一个流，并继续将元素传递给该流。**Source.single(req).runWith(sink)(mat)**
s"<h1>Say hell
浏览 1提问于2019-11-29得票数 0
我已经添加了最新的akka-http到我的项目，但这包括非常老的2.4.19版本的akka-演员。因此，我还在依赖项中添加了akka-参与者版本2.5.4。我的maven配置如下： <dependency> <a
浏览 1提问于2017-08-27得票数 2
回答已采纳
1回答
我使用Akka HTTP在post请求中发送数据，并将其累积到一个列表中。我需要对这些数据执行一些规则，这些规则将对批处理进行聚合。要创建批处理，我需要在固定的时间内对数据进行窗口化 data = List(
Map("a" -> 1.0, "b" -> 267.0, "c" -> 26.0, "
浏览 2提问于2018-12-17得票数 0
我们正在开发一个web应用程序，从一个源流视频和从多个地点的音频。在未来，我们也可以考虑从多个地点播放视频。如何使用Azure媒体服务多路复用几个AV源。请注意，“位置”是故意用来表示AV源将位于不同的物理位置，因此不能在一台计算机上在本地进行多路复用。
浏览 6提问于2015-03-24得票数 0
回答已采纳
1回答
我正在尝试创建一个可伸缩的管道，它将从Kafka获取消息并将其发送到多个http端点。到目前为止，我尝试的是一个(普通的Kafka)消费者，它使用来自Kafka主题的消息，并使用Akka-Http将它们异步发送到端点。所以我有一种卡夫卡连接器。问:考虑到消息的目的地不是静态的，并且每个消息可能会有所不同，将应用程序重写为Kafk
浏览 38提问于2018-06-06得票数 0
2回答
我对Akka Streams和Akka HTTP非常陌生。 val os = new ByteArrayOut
浏览 0提问于2016-12-14得票数 9
我正在组织一个小的SBT项目，并学习如何使用akka演员。我能够得到一个简单的示例，只使用akka，但是一旦我使用外部库，就会停止工作。External projects like Alpakka, Persistence plugins or Akka HTTP etc. have their own version numbers(Lscala/Function2;)Lakka/actor/FunctionRef;
我的依赖关系如下所示
浏览 2提问于2018-01-21得票数 4
我使用akka-streams的ActorPublisher参与者作为每个连接发送到传入的WebSocket或HTTP连接的数据的流。ActorPublisher的是通过提供一个下游可以接受的元素数量来定期请求数据。如果需求为0时，我不应该发送更多的元素。为了流，我使用akka-http的能力将</em
浏览 0提问于2017-06-13得票数 3
我有一个使用akka流进行数据处理的akka-http应用程序。因此，使用Source[Result, _]完成请求以免费获得跨HTTP边界的背压是有意义的。版本：
这是代码的简化版本，它工作得很好。entity(asSourceOf
浏览 2提问于2017-07-06得票数 1
回答已采纳
1回答
我有一个数据流，我想要向现有的数据流添加新的价值。代码如下所示 Stream<List<Points>> _points;
_points.sink.add(values); 这是可能的吗，或者我必须找到一种不同的方法？
浏览 17提问于2021-09-29得票数 0
xmlR = ElementTree.dump(tree)xmlR是一个'NoneType‘，在调用Azure函数时只返回200个，但没有返回任何内容(我在init文件的主函数中调用了我不知道这是否是正确的方式，或是否有任何其他方式在ADF做所有这些。
我想要的是--将数据从api端点(返回xml主体)复制到sql服务器。当我无法通过ADF活动传递所需的xml主体时，我想编写一个python脚本。是否可以使用A
浏览 3提问于2022-10-02得票数 0
回答已采纳
想要使用数据融合将文件发送到http端点url。在流水线完成时将该http调用作为流水线告警。
这不管用。正在从API获取500响应。有没有人能告诉我如何发送这个文件？如果这可以实现与http插件作为接收器，请让我知道步骤。
浏览 3提问于2021-09-13得票数 1
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
