使用 Scalazon 创建 Kinesis Stream 问题

Question

我正在按照 here 上的 Scalazon 示例创建 Kinesis 流。下面一段代码：

val streamListFuture = for {
  s <- Kinesis.streams.list
} yield s

给出以下错误：

[error] KinesisStatsWriter.scala:51: value map is not a member of object io.github.cloudify.scala.aws.kinesis.Requests.ListStreams
[error]       s <- Kinesis.streams.list

如果我不使用 a for comprehension 并调用 val createStream = Kinesis.streams.list，则没有错误。似乎无法弄清楚为什么。

同样，下面的代码：

val createStream = for {
  s <- Kinesis.streams.create(name)
} yield s

产生类似的错误：

[error] KinesisStatsWriter.scala:64: value map is not a member of io.github.cloudify.scala.aws.kinesis.Requests.CreateStream
[error]       s <- Kinesis.streams.create(name)

感谢帮助！

Answer 1

作者在这里，仅当您包含将请求隐式转换为 Futures（称为 ImplicitExecution）的模块时，for-comprehension 才有效。尝试添加以下 import 语句（查看库 README 中的示例代码）。

import io.github.cloudify.scala.aws.kinesis.Client.ImplicitExecution._

使用 Scalazon 创建 Kinesis Stream 问题

Issue Creating Kinesis Stream with Scalazon

scala

amazon-kinesis

scalazon