如何使用akka stream alpakka编写带头部的CSV文件？_如何使用alpakka，spring boot和Akka-stream初始化一个连续运行的流？_如何在我的API中上传CSV文件的内容，使用CSV的头部作为请求头部 - 腾讯云开发者社区

csv、akka-stream、alpakka

我看不到它，因此我转向slack问:有没有一种方法可以用akka stream alpakka写一个csv文件？我唯一能看到的就是https://doc.akka.io/docs/alpakka/current/data-transformations/csv.html#csv-formatting 但不能以某种方式反向操作csv

浏览 16提问于2020-07-10得票数 1

2回答

在文件更改时更新流

scala、akka、akka-stream

使用下面的代码，我使用Akka streams读取并打印文件的内容： package playground import akka.actor.ActorSystemimport akka.stream.scaladsl.{FileIO, Framing, Sink, Source}import akka

浏览 47提问于2019-09-24得票数 0

回答已采纳

1回答

FileTailSource抛出空指针异常

scala、akka-stream、alpakka

我编写了下面的Alpakka代码val resource = getClass.getResource("countrycapital.csv"countrycapital.csv“的文件。我的目标是为该文件构建一个Akka流源，并处理该文件的所有记录。&quo

浏览 3提问于2017-10-01得票数 0

回答已采纳

1回答

使用Alpakka在弹性中插入文档

scala、elasticsearch、akka-stream、alpakka

我正在努力学习如何使用Alpakka，并设置了一个测试，以编写一个文档给弹性。通过阅读文档，包括，编写了以下内容：import akka.stream.alpakka.elasticsearch.scaladsl.ElasticsearchSinkimport akka.stream.alpakka.elasticsea

浏览 10提问于2022-10-23得票数 0

回答已采纳

1回答

akka流alpakka csv:跳过异常，解析下一行

scala、akka、akka-stream、alpakka

我正在使用Alpakka来解析csv文件。版本"com.lightbend.akka“%% "akka-stream-alpakka- csv”% 0.20我有csv文件，带有未关闭的引号。email"test@emample.comtest@emample.com 我想跳过不好<

浏览 1提问于2018-11-30得票数 0

1回答

Alpakka和Akka版本兼容性问题

scala、sbt、akka、alpakka

当我试图构建我的项目时，项目生成失败，出现“提取产品结构失败”错误。我怀疑与我所使用的Alpakka和Akka版本有关的东西。这是我的build.sbt文件：lazy val akkaVersion = "2.6.14"" %% "akka

浏览 4提问于2021-05-12得票数 0

回答已采纳

1回答

Scala将实时/正在增长的文件流

scala、akka、streaming、akka-stream、akka-actor

我的Scala应用程序启动了一个将文件写入磁盘的外部进程。在一个单独的线程中，我希望读取该文件并将其内容复制到OutputStream，直到进程完成，文件不再增长。有几个边缘情况需要考虑：线程复制的速度可能比进程正在写入的要快。换句话说，当文件还在增长时，它可能会到达文件的末尾。顺便说一句，我可以向线程传递一个processComp

浏览 1提问于2018-04-21得票数 0

回答已采纳

3回答

如何使用Akka* HTTP或Alpakka访问unix域套接字上的REST？*

akka-http、alpakka

我想使用/var/lib/docker.sock unix域套接字访问docker。我看到了一些例子，您可以使用(现代版本的) curl调用API，如下所示：其中，REST命令是在/containers/json路径中表示的。我很兴奋地看到Alpakka Unix域套接字适配器，但您

浏览 0提问于2018-07-27得票数 4

回答已采纳

2回答

关于slick DB，slick配置文件是如何工作的？

scala、slick、akka-stream、alpakka

我很难理解如何使用光滑的轮廓。我正试图通过Alpakka JDBC插件使用与Akka流一起使用的流畅工具。akka.stream.ActorMaterializer import akka.stream.alpakka.slick.s

浏览 0提问于2018-08-23得票数 0

回答已采纳

2回答

Alpakka S3连接问题

scala、amazon-s3、playframework、akka、alpakka

为了存储文件，我试图使用Alpakka S3连接到minio实例，但是自从我将库版本从1.1.2升级到2.0.0之后，我遇到了一些问题。 package services import akka.actor.Actor

浏览 21提问于2020-05-21得票数 2

回答已采纳

2回答

在Scala中使用package？

scala

我有一个使用akka的scala项目。我希望执行上下文在整个项目中都可用。因此，我创建了一个包对象，如下所示：import akka.stream.ActorMaterializer .withPort(9042)

浏览 2提问于2019-03-07得票数 0

1回答

我在使用alpakka的XmlParsing Flow时遇到问题 val files: List[String] = ... // file paths locally on disk // simple，这些元素是正确的，并且与第一个文件的期望值相匹配。/StreamSupervisor-0/flow-0-0-ignoreSink] Error in stage [akka.stream.

浏览 16提问于2018-12-21得票数 0

回答已采纳

2回答

如何在Slick中将`FixedSqlAction`转换为`StreamingDBIO`？

slick、akka-stream、slick-3.0、alpakka

我正在使用Alpakka和Slick模块创建一个akka-stream，但我遇到了类型不匹配的问题。其中一个分支是获取其表中的发票总数： def getTotal(implicit session: SlickSession) = { val query = TableQuery[Tables.Invoice].length.result } 但是结束行不能编

浏览 47提问于2021-10-22得票数 0

回答已采纳

1回答

使用Alpakka* Mongo的MongoDB反应流运行时依赖错误*

mongodb、scala、akka、reactive-streams、alpakka

特别是，当我尝试使用Mongo连接器提供的NoClassDefFoundError方法时，我得到了一个成功/失败包装器的MongoSink.insertOne。一个完整的堆栈跟踪： at akka.stream.alpakka.mongodb.scaladsl.Mo

浏览 0提问于2020-12-30得票数 0

回答已采纳

1回答

通过Akka或Play从S3以压缩方式下载多个文件

amazon-web-services、playframework、akka-stream、akka-http、alpakka

我有一个S3结构，它是火花作业的结果，它编写分区的CSV文件，如下所示。bucketA cleaned-data1 part001....csv part002....csv我需要的是能够有一个Akka端点，它指向输出文件名，将所有部分下载为zip文件：https://.

浏览 0提问于2019-06-30得票数 0

2回答

FTP无法从mesos码头容器中运行。

scala、docker、ftp、akka-stream、dcos

我在akka steams上有scala应用程序。因此，我的应用程序流程如下：我的应用程序在本地工作，它可以连接到服务器我有个问题：我可以肯定地说那个文件仍然

浏览 1提问于2017-01-31得票数 4

回答已采纳

1回答

上传/下载文件的问题-http/akka-streams

amazon-s3、akka-stream、akka-http、alpakka

我正在尝试使用akka-streams和akka-http以及alpakka库下载/上传文件到亚马逊S3。我看到两个可能相关的问题..。处理请求时出错：“子流源没有在5000毫秒内物化”。完成500内部服务器错误响应。若要更改默认异常处理行为，请提供自定义ExceptionHandler。akka

浏览 4提问于2017-09-19得票数 2

2回答

用Alpakka手动确认ActiveMQ消息

java、akka、activemq、akka-stream、alpakka

我正在用Java实现Alpakka，用于在ActiveMQ队列中消费和生产。我可以成功地从队列中消费，但还不能实现应用程序级别的消息确认。我的目标是使用队列中的消息，并将它们发送到另一个参与者进行处理。当该参与者完成处理后，我希望它能够控制ActiveMQ中消息的确认。这可能是通过向另一个可以进行确认的参与者发送消息、调用消息本身上的确认函数或其他方式来实现的。在我的测试中，将2条消息放入AlpakkaTest队列，然后这段代码尝试使用和确认它们。但

浏览 0提问于2017-08-21得票数 4

回答已采纳

2回答

使用akka-stream-alpakka从s3下载pdf文件

scala、amazon-s3、akka-stream、alpakka

我正在尝试使用akka-stream-alpakka连接器从S3下载pdf文件。我有s3路径，并尝试在alpakka s3Client上使用包装器方法下载pdf。ByteString, NotUsed] = { source在我的主代码中，我调用上述方法并尝试将其转换为文件

浏览 15提问于2020-02-03得票数 0

回答已采纳

1回答

为什么Akka流应用程序不正常终止？

scala、akka-stream、alpakka

我使用Alpakka Cassandra库编写了这个简单的应用程序import akka.stream.{ActorMaterializer, ClosedShape}importakka

浏览 0提问于2017-09-12得票数 2

回答已采纳

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云