1

ライブ ツイートをストリーミングするための要件の 1 つとして、Iteratee と関連する API を学習しています。Play 2.1 と Scala 2.10 を使用。ツイートをMongoDBに保存した結果も生成するIterateeを使用する最良の方法は次のとおりですか?

val wsStream = new Enumerator[Array[Byte]] {
  def apply[A](iteratee: Iteratee[Array[Byte], A]) = {
    WS.url("https://stream.twitter.com/1.1/statuses/filter.json?track=" + term)
      .sign(OAuthCalculator(Twitter.KEY, tokens))
      .get(_ => iteratee)
  }
}

wsStream.apply(Iteratee.foreach(bytes => saveTweetToMongo(bytes)))
4

1 に答える 1

2

複数の iteratee を同じ列挙子に適用できることに注意してください。順番に astreamingTweetIterateeと aを作成し、saveTweetToMongoIterateeツイートを提供する列挙子に両方を適用できます。

loggingIterateeREPL でプロトタイピングを行っているときに、すべてを STDOUT に転送する単純なものを作成することがよくあります。それと、書いている iteratee の両方を同じ列挙子に適用します。

ツイートをクライアントにストリーミングするために WebSocket を使用したいと思いますか? Play! に付属のチャット デモを見ると、どうすればよいかがわかります。

于 2013-03-14T17:38:01.027 に答える