要求在Twitter上跟蹤某些URL。將推文存儲到Mongodb中
1)可以在Twitter Track參數中指定部分URL模式嗎?例如如果我想搜索包含http://abc.co/的所有網址,其中包括http://abc.co/122,http://abc.co/456等。這可能與Twitter流API?
2)什麼是有效的方式來存儲所有的鳴叫到MongoDB?推文將用於分析目的。
我使用Scala的2.10和MongoDB
更新:好吧,瞭解一些Iteratee概念挖後,我已經把一個快速測試如下
WS.url("https://stream.twitter.com/1.1/statuses/filter.json?track=" + term)
.sign(OAuthCalculator(Twitter.KEY, tokens))
.get(_ => printingIteratee)
def printingIteratee = Iteratee.foreach[Array[Byte]] { chunk =>
val json = Json.parse(new String(chunk))
val user = (json \ "user" \ "screen_name").as[String]
val content = (json \ "text").as[String]
println("user " + user)
println("content " + content)
}
以上Iteratee是一個測試是爲了副作用而不返回任何東西。
我想要拿出一個採用Array [Byte]並創建一個對象來存儲在MongoDB中的Iteratee。有一個快速瀏覽Iteratee.fold和很少的方法,但仍然不太確定如何創建一個接受Array [Byte]並生成一個可存儲到MongoDB的對象(如case class Tweet)的Iteratee。任何創建這樣的Iteratee指針將不勝感激。
就#2而言,您應該編寫代碼,然後優化它,您可以在[代碼評論](http://codereview.stackexchange.com/) – EECOLOR 2013-03-11 10:04:56
#2發佈它也非常類似於您的其他問題[收集實時鳴叫不斷,存儲到本地數據存儲](http://stackoverflow.com/questions/15280565/collect-real-time-tweets-continuously-store-into-local-datastore) – EECOLOR 2013-03-11 10:17:11