【发布时间】:2014-02-12 20:46:47
【问题描述】:
作为我大学最后一年项目的一部分,我正在使用图熵分析 Twitter 数据。简要概述目的:
- 我想收集来自某个地区(伦敦)的所有推文,其中包含关键字“感冒”、“流感”等。这部分是使用 Streaming API 完成的。
- 然后,我想访问每个用户(在上一节中收集到的关于生病的推文)的关注者列表和关注者,以便能够构建图表以进行进一步分析。我在这里卡住了。
我假设第二部分我应该使用 Search API,但即使对于单个用户,我也会不断收到错误 88。
下面是我用于第一部分的代码:
final TwitterStream twitterStream = new TwitterStreamFactory(cb.build())
.getInstance();
StatusListener listener = new StatusListener() {
public void onStatus(Status status) {
User user = status.getUser();
long userid = user.getId();
String username = status.getUser().getScreenName();
String content = status.getText();
GeoLocation geolocation = status.getGeoLocation();
Date date = status.getCreatedAt();
if (filterText(content)) {
System.out.println(username+"\t"+userid);
System.out.println(content);
System.out.println(geolocation);
System.out.println(date);
try {
getConnections(userid);
} catch (TwitterException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
//OTHER LISTENER METHODS
};
twitterStream.addListener(listener);
// London
double lat3 = 51.23;
double lat4 = 51.72;
double lon3 = -0.56;
double lon4 = 0.25;
double[][] bb = { { lon3, lat3 }, { lon4, lat4 } };
FilterQuery fq = new FilterQuery();
fq.locations(bb);
twitterStream.filter(fq);
private static boolean filterText(String tweet) {
return tweet.contains("flu")
|| tweet.contains("cold")
|| tweet.contains("cough")
|| tweet.contains("virus");
}
这就是我试图完成第二部分的内容:
private static void getConnections(long id) throws TwitterException {
Twitter twitter = new TwitterFactory().getInstance();
long lCursor = -1;
IDs friendsIDs = twitter.getFriendsIDs(id, lCursor);
System.out.println(twitter.showUser(id).getName());
System.out.println("==========================");
do
{
for (long i : friendsIDs.getIDs())
{
System.out.println("follower ID #" + i);
System.out.println(twitter.showUser(i).getName());
}
}while(friendsIDs.hasNext());
}
有什么建议吗?
【问题讨论】:
标签: twitter twitter4j twitter-streaming-api