腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
akka
stream
alpakka
编写
带
头部
的
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
-xml可以处理多个xml
文件
吗?
xml
、
scala
、
akka-stream
、
alpakka
我在
使用
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}import
akka
浏览 0
提问于2017-09-12
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
接口测试 unittest实用教程
面向对象的编程-Application 39
使用Java Streams查询数据库
selenim自动化数据驱动测试实例读取csv文件实现批量登录账号
Python的小数据存储,用什么格式更有逼格?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券