如何解决Twitter4j 为 getCreatedAt 和 getCountry 获取空白或空值
我正在使用 Twitter4J 流式传输一些 Twitter 数据,并且能够生成推文文本。 该推文由 TwitterConsumer 类使用,该类将文本保存到 Kafka。 到目前为止,一切都按预期工作。 我的问题是我试图获取推文的位置(国家代码就足够了)的日期和时间。我知道该位置可能为空,但就我而言,日期/时间和位置始终为空或为空。我一定是做错了什么。
样本输出;
[Twitter4J 异步调度程序[0]] 信息 uom_bigdataAss1.producer.TwitterProducer - 创建于:[Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - 位置:无位置 [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - delta plus
- 令人担忧的变体。更具传染性,甚至可以逃脱疫苗。我们将继续了解更多关于…… [Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - 创建于:[Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - 用户:[Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - 用户名:[Thread-3] INFO uom_bigdataAss1.consumer.TwitterConsumer - _________________
public class TwitterProducer {
final Logger logger = LoggerFactory.getLogger(TwitterProducer.class);
Thread twitterConsumerThread = null;
//Queue for tweets
private LinkedBlockingQueue<Status> queue;
//stream of tweets
private TwitterStream twitterStream;
private BlockingQueue<String> msgQueue = new LinkedBlockingQueue<>(100);
public static void main(String[] args) {
new TwitterProducer().run();
}
// Twitter Client
public void setTwitterStream(BlockingQueue<String> msgQueue){
/** Setting up a connection */
ConfigurationBuilder cb = new ConfigurationBuilder();
cb.setDebugEnabled(true)
.setoAuthConsumerKey(TwitterConfig.CONSUMER_KEYS)
.setoAuthConsumerSecret(TwitterConfig.CONSUMER_SECRETS)
.setoAuthAccesstoken(TwitterConfig.TOKEN)
.setoAuthAccesstokenSecret(TwitterConfig.SECRET);
this.twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
}
private void run(){
logger.info("Setting up");
// 1. Twitter Stream
setTwitterStream(msgQueue);
this.queue = new LinkedBlockingQueue<Status>();
StatusListener listener = new StatusListener() {
@Override
public void onStatus(Status status) {
try {
queue.offer(status,5000,TimeUnit.MILLISECONDS);
logger.info("Created on:",status.getCreatedAt().getTime());
Place place = status.getPlace();
if (place != null ) {
logger.info("Created on:",place.getCountry());
}
} catch (InterruptedException e) {
// Todo Auto-generated catch block
logger.error("BlockinQueue Full",e);
}
}
@Override
public void onDeletionNotice(StatusDeletionNotice sdn) {
}
@Override
public void onTrackLimitationNotice(int i) {
}
@Override
public void onScrubGeo(long l,long l1) {
}
@Override
public void onException(Exception e) {
e.printstacktrace();
}
@Override
public void onStallWarning(StallWarning warning) {
}
};
twitterStream.addListener(listener);
FilterQuery query = new FilterQuery();
String keywords[] = {"covid","vaccine"};
query.track(keywords);
query.language("en");
twitterStream.filter(query);
// Shutdown Hook
Runtime.getRuntime().addShutdownHook(new Thread( () -> {
logger.info("Application is Now stopping!");
twitterStream.shutdown();
//logger.info("Closing Producer");
//producer.close();
logger.info("Closing twitterConsumer");
this.twitterConsumerThread.interrupt();
logger.info("Finished closing");
logger.info("\n Application End");
}));
logger.info("Running Twitter Consumer");
TwitterConsumer twitterConsumer = new TwitterConsumer(this.queue);
this.twitterConsumerThread = new Thread(twitterConsumer);
twitterConsumerThread.start();
}
}
任何想法可能发生/导致什么?
解决方法
改变你的日志语句
logger.info("Created on: {}",status.getCreatedAt().getTime());
和
logger.info("Created on: {}",place.getCountry());
您缺少 {} 占位符
以上改动后,日志将类似于
Created on: 1624430231000
Created on: India
检查http://www.slf4j.org/manual.html#typical_usage
此外,并非所有状态都会包含国家/地区信息。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。