0

Kinesis ストリームを作成するために、こちらの Scalazon の例に従っています。次のコード:

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 内包表記と 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)

助けてくれてありがとう！

4

1 に答える 1

1

Futuresここで作成すると、for-comprehension は、リクエストを暗黙的に変換するモジュール(と呼ばれる)を含める場合にのみ機能しますImplicitExecution。次のステートメントを追加してみてくださいimport(ライブラリの README にあるサンプル コードを参照してください)。

import io.github.cloudify.scala.aws.kinesis.Client.ImplicitExecution._
于 2015-03-07T19:12:57.727 に答える