如何在hadoop中使用twitter搜索api?

ecfdbz9o  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(382)

我是hadoop新手。最近我学到了很多关于hadoop的知识。我已经成功地使用了流式api,并将twitter数据导入hdfs。现在我正在尝试使用搜索api,这样我就可以得到历史推文,但我找不到任何网上的例子。有一堆流式api的例子,但找不到一个搜索api。

kgsdhlau

kgsdhlau1#

你没有提到编程语言,所以我假设你会使用java。推荐使用twitter4j库,其文档中有一些搜索示例,例如:

public class SearchTweets {
/**
 * Usage: java twitter4j.examples.search.SearchTweets [query]
 *
 * @param args search query
 */
public static void main(String[] args) {
    if (args.length < 1) {
        System.out.println("java twitter4j.examples.search.SearchTweets [query]");
        System.exit(-1);
    }
    Twitter twitter = new TwitterFactory().getInstance();
    try {
        Query query = new Query(args[0]);
        QueryResult result;
        do {
            result = twitter.search(query);
            List<Status> tweets = result.getTweets();
            for (Status tweet : tweets) {
                System.out.println("@" + tweet.getUser().getScreenName() + " - " + tweet.getText());
            }
        } while ((query = result.nextQuery()) != null);
        System.exit(0);
    } catch (TwitterException te) {
        te.printStackTrace();
        System.out.println("Failed to search tweets: " + te.getMessage());
        System.exit(-1);
    }
}

在github repo上提供:https://github.com/yusuke/twitter4j/blob/master/twitter4j-examples/src/main/java/twitter4j/examples/search/searchtweets.java
另外,确保你了解如何使用时间表。

相关问题