我需要从twitterapi流直播推特,然后分析它们。我应该用Kafka直接获得推特或Spark流或两者?
7fhtutme1#
根据您选择的语言,我将使用以下列出的库之一:https://developer.twitter.com/en/docs/developer-utilities/twitter-libraries. 无论你选择哪一个,你都将使用 statuses/filter 在twitter api中,请熟悉以下文档:https://developer.twitter.com/en/docs/tweets/filter-realtime/api-reference/post-statuses-filter.html
statuses/filter
ogsagwnx2#
您可以使用kafka connect接收tweets,然后使用kafka流或ksql分析它们。看看这篇文章,它描述了这一点。
2条答案
按热度按时间7fhtutme1#
根据您选择的语言,我将使用以下列出的库之一:https://developer.twitter.com/en/docs/developer-utilities/twitter-libraries. 无论你选择哪一个,你都将使用
statuses/filter
在twitter api中,请熟悉以下文档:https://developer.twitter.com/en/docs/tweets/filter-realtime/api-reference/post-statuses-filter.htmlogsagwnx2#
您可以使用kafka connect接收tweets,然后使用kafka流或ksql分析它们。看看这篇文章,它描述了这一点。