twitter4j - доступ к информации твита из потокового API - PullRequest
Новая
       14

twitter4j - доступ к информации твита из потокового API

5 голосов
/ 22 февраля 2012

Моя цель - собрать все твиты, содержащие слова «Франция» и «Германия», а также собрать связанные метаданные (например, географические координаты, прикрепленные к твиту).Я знаю, что эти метаданные доступны, но я не могу понять, как получить к ним доступ с помощью библиотеки Java, которую я использую: «twitter4j».

Хорошо, так что то, что у меня есть, взято из кодаобразцы на сайте twitter4j.Он распечатывает все твиты, содержащие выбранные мной ключевые слова, так как они предоставляются в реальном времени потоковым API Twitter.Я вызываю метод filter для моего объекта TwitterStream, и это обеспечивает поток.Но мне нужно больше контроля.А именно, я хотел бы иметь возможность:

1) записывать твиты в файл;2) распечатывать только первые 1000 твитов;3) получить доступ к другим метаданным, прикрепленным к твиту (метод filter просто печатает имя пользователя и сам твит).

Вот код, который у меня есть: 

import twitter4j.FilterQuery;
import twitter4j.Status;
import twitter4j.StatusDeletionNotice;
import twitter4j.StatusListener;
import twitter4j.TwitterException;
import twitter4j.TwitterStream;
import twitter4j.TwitterStreamFactory;
import twitter4j.conf.ConfigurationBuilder;

public class Stream {
    public static void main(String[] args) throws TwitterException {

    ConfigurationBuilder cb = new ConfigurationBuilder();
    cb.setDebugEnabled(true);
    cb.setOAuthConsumerKey("bbb");
    cb.setOAuthConsumerSecret("bbb");
    cb.setOAuthAccessToken("bbb");
    cb.setOAuthAccessTokenSecret("bbb");

    TwitterStream twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
    StatusListener listener = new StatusListener() {

        public void onStatus(Status status) {
            System.out.println("@" + status.getUser().getScreenName() + " - " + status.getText());
        }

        public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {
            System.out.println("Got a status deletion notice id:" + statusDeletionNotice.getStatusId());
        }

        public void onTrackLimitationNotice(int numberOfLimitedStatuses) {
            System.out.println("Got track limitation notice:" + numberOfLimitedStatuses);
        }

        public void onScrubGeo(long userId, long upToStatusId) {
            System.out.println("Got scrub_geo event userId:" + userId + " upToStatusId:" + upToStatusId);
        }

        public void onException(Exception ex) {
            ex.printStackTrace();
        }
    };

    FilterQuery fq = new FilterQuery();
    String keywords[] = {"France", "Germany"};

    fq.track(keywords);

    twitterStream.addListener(listener);
    twitterStream.filter(fq);      
}
}

Ответы [ 3 ]

5 голосов
/ 23 февраля 2012

Посмотрев на это свежим взглядом, я понял решение (что было довольно очевидно). Редактирование следующей части кода: 

public void onStatus(Status status) {
        System.out.println("@" + status.getUser().getScreenName() + " - " + status.getText());
    }

позволяет мне получить доступ к другим метаданным. Например, если я хочу получить доступ к дате твита, мне просто нужно добавить следующее: 

System.out.println(status.getCreatedAt());
0 голосов
/ 20 декабря 2013

Для записи твитов в файл: 

FileWriter file = new FileWriter(....);

public void onStatus(Status status) {
    System.out.println("@" + status.getUser().getScreenName() + " - " + status.getText() + " -> "+ status.getCreatedAt());
    try {
        file.write(status.getUser().getScreenName() + " - " + status.getText() + " -> "+ status.getCreatedAt() +"\n");
        file.flush();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}
0 голосов
/ 25 августа 2013

Ошибка 401 возникает, когда API пытается получить доступ к некоторой информации, которую в настоящее время не удается получить. Так что вам нужно проверить разрешение, которое разрешено в твиттере. Измените его на READ, WRITE и ... для полного доступа к API. Или может быть проблема, поскольку вы можете использовать прокси-сервер. Поэтому укажите детали прокси, используя следующие команды. 

 System.getProperties().put("http.proxyHost", "10.3.100.211");
        System.getProperties().put("http.proxyPort", "8080");
...