使用Akka Camel访问Twitter以返回JSON
使用Akka Camel访问Twitter以返回JSON
提问于 2017-02-17 19:09:34
我使用的是HTTP方法，使用的是URL "https://stream.twitter.com/1.1/statuses/filter.json“，在正文中，我发布了我想从其中获得的键/值--例如"track=london”。一切都很顺利。
现在我正试着改用AKKA-骆驼，我正在使用他们的twitter用户。我使用的端点URL为：
def endpointUri: String = s"twitter:////search?type=direct&keywords=${Settings.queryList()}&consumerKey=${tweeterCredentials.consumerKey}&consumerSecret=${tweeterCredentials.consumerSecret}&accessToken=${tweeterCredentials.accessToken}&accessTokenSecret=${tweeterCredentials.accessTokenSecret}"我收到了twitter的回复，但它不是在JSON中，也不是像以前一样提供的关于twitter的信息。它只返回tweet文本，但在我得到需要分析的全部元数据之前。
有人知道如何像以前一样配置Camel URI来返回JSON和整个元数据吗？
谢谢
回答 1
Stack Overflow用户
回答已采纳
发布于 2017-02-19 19:00:56
我使用了以下语法来完成这个任务：
def endpointUri: String = s"twitter://streaming/filter?type=event&keywords=${Settings.queryList()}&consumerKey=${tweeterCredentials.consumerKey}&consumerSecret=${tweeterCredentials.consumerSecret}&accessToken=${tweeterCredentials.accessToken}&accessTokenSecret=${tweeterCredentials.accessTokenSecret}"其中: Settings.queryList返回一个以逗号分隔的关键字列表。对象tweeterCredentials保存来自Tweeter的访问站点的键。
另外，有必要在Camel中设置这样的autoAck：
覆盖def autoAck = true
这可以防止超时异常。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/42305675
复制相关文章
相似问题
腾讯云开发者
