scala - 使用 Scalazon 创建 Kinesis Stream 的问题

Question

我正在按照此处的 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

如果我不使用 for comprehension 和 call 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）的模块时，理解才有效。尝试添加以下import语句（查看库 README 中的示例代码）。

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