标签: twitter-streaming-api

鉴于这个网址,我应该看到伦敦周围的推文,对吗？

http://stream.twitter.com/1/statuses/filter.json?locations=51.23,-0.28,51.68,0.25

但没有任何反应:(

我尝试了不同的区域,但我根本无法得到任何东西,虽然我正在尝试在doc中给出的区域,但都没有使用cURL/POST.

当我添加一个关键字track参数时,我得到了大量的推文 - 但这并不意味着该位置有效(位置边界框是逻辑OR和其他过滤参数).

http://stream.twitter.com/1/statuses/filter.json?track=royalwedding&locations=51.23,-0.28,51.68,0.25

谢谢 !

我正在使用 Twitter Streaming API 来获取推文中包含的图像，并在我的 Android 应用程序中显示它们。表示图像的媒体对象包含一个 media_url 字段，它是图像的直接链接，以及一个名为 size 的 JSON 对象，其中包含该图像可用的不同尺寸。问题是，我怎样才能得到这样调整大小的图像？我想直接从 Twitter 下载缩略图，并且由于大小对象包含一个拇指字段，所以应该可以，但是如何？我已经尝试将 ?size=thumb 连接到 media_url 但它没有用。媒体对象示例：

{"id":897839774635053000,"id_str":"897839774635053056","indices":
[75,98],"media_url":"http://pbs.twimg.com/media/DHXEhKBW0AAKhf3.jpg",
"media_url_https":"https://pbs.twimg.com/media/DHXEhKBW0AAKhf3.jpg",
"url":"https://REMOVED/4NcW6720Zj","display_url":"pic.twitter.com/4NcW6720Zj",
"expanded_url":
"https://twitter.com/darioolly/status/897840123924164608/photo/1",
"type":"photo",

"sizes":{"thumb":{"w":150,"h":150,"resize":"crop"},
         "medium":{"w":720,"h":711,"resize":"fit"},
         "small":{"w":680,"h":672,"resize":"fit"},
         "large":{"w":720,"h":711,"resize":"fit"}}}

我正在尝试通过经典的 Twitter 流媒体示例来学习 Kafka。我正在尝试使用我的生产者将基于 2 个过滤器的 Twitter 数据流式传输到同一主题的不同分区。例如，Twitter 数据的一个分区的 track='Google' 和另一分区的 track='Apple'。

class Producer(StreamListener):
    def __init__(self, producer):
        self.producer = producer

    def on_data(self, data):
        self.producer.send(topic_name, value=data)
        return True

    def on_error(self, error):
        print(error)


twitter_stream = Stream(auth, Producer(producer))
twitter_stream.filter(track=["Google"])

如何添加另一个轨道并将该数据流式传输到另一个分区。

同样，我如何让我的消费者从特定分区消费。

consumer = KafkaConsumer(
    topic_name,
     bootstrap_servers=['localhost:9092'],
     auto_offset_reset='latest',
     enable_auto_commit=True,
     auto_commit_interval_ms =  5000,
     max_poll_records = 100,
     value_deserializer=lambda x: json.loads(x.decode('utf-8')))

Twitter Stream API是否可以按位置字段过滤推文？正如您在下面的示例JSON条目中看到的那样,有"location":"philippines"字段 - 值.现在,我想要的是通过位置字段过滤来自该位置的推文.但是不要误会我的意思.我不是在谈论GEO标签过滤器.

这可能吗？

{"geo":null,"in_reply_to_screen_name":null,"truncated":false,"text":"RT @BreakingNewsPH: Typhoon hits Taiwan after pummeling Philippines: Typhoon Nanmadol slammed into\u2026 http:\/\/t.co\/rF3jbVU #breakingnews","in_reply_to_user_id_str":null,"contributors":null,"retweeted":false,"retweet_count":1,"entities":{"hashtags":[{"text":"breakingnews","indices":[120,133]}],"urls":[{"indices":[100,119],"display_url":"goo.gl\/fb\/JVdpj","expanded_url":"http:\/\/goo.gl\/fb\/JVdpj","url":"http:\/\/t.co\/rF3jbVU"}],"user_mentions":[{"indices":[3,18],"name":"Breaking News PH","screen_name":"BreakingNewsPH","id":190144401,"id_str":"190144401"}]},"coordinates":null,"retweeted_status":{"geo":null,"in_reply_to_screen_name":null,"truncated":false,"text":"Typhoon hits Taiwan after pummeling Philippines: Typhoon Nanmadol slammed into\u2026 http:\/\/t.co\/rF3jbVU #breakingnews","in_reply_to_user_id_str":null,"contributors":null,"retweeted":false,"retweet_count":1,"entities":{"hashtags":[{"text":"breakingnews","indices":[100,113]}],"urls":[{"indices":[80,99],"display_url":"goo.gl\/fb\/JVdpj","expanded_url":"http:\/\/goo.gl\/fb\/JVdpj","url":"http:\/\/t.co\/rF3jbVU"}],"user_mentions":[]},"coordinates":null,"place":null,"source":"\u003Ca href=\"http:\/\/www.google.com\/support\/youtube\/bin\/answer.py?hl=en&answer=164577\" rel=\"nofollow\"\u003EGoogle\u003C\/a\u003E","created_at":"Mon Aug 29 04:16:31 +0000 2011","in_reply_to_user_id":null,"user":{"listed_count":19,"favourites_count":0,"profile_sidebar_fill_color":"252429","location":"Philippines","profile_background_tile":false,"lang":"en","profile_link_color":"2FC2EF","description":"Follow us to receive round-the-clock Philippine Breaking News updates directly on your Twitter account!","default_profile_image":false,"default_profile":false,"verified":false,"profile_sidebar_border_color":"181A1E","notifications":null,"time_zone":"Hong Kong","created_at":"Mon Sep 13 05:14:02 +0000 2010","followers_count":804,"following":null,"profile_use_background_image":true,"profile_background_image_url_https":"https:\/\/si0.twimg.com\/images\/themes\/theme9\/bg.gif","profile_image_url":"http:\/\/a3.twimg.com\/profile_images\/1130204413\/breakingnewsph-logo-small_normal.png","show_all_inline_media":false,"follow_request_sent":null,"geo_enabled":false,"profile_background_color":"1A1B1F","protected":false,"contributors_enabled":false,"profile_background_image_url":"http:\/\/a1.twimg.com\/images\/themes\/theme9\/bg.gif","url":"http:\/\/www.breakingnews.ph","screen_name":"BreakingNewsPH","name":"Breaking News PH","friends_count":210,"profile_image_url_https":"https:\/\/si0.twimg.com\/profile_images\/1130204413\/breakingnewsph-logo-small_normal.png","id":190144401,"id_str":"190144401","is_translator":false,"statuses_count":51981,"utc_offset":28800,"profile_text_color":"666666"},"in_reply_to_status_id":null,"favorited":false,"id":108030240370073602,"possibly_sensitive":false,"in_reply_to_status_id_str":null,"id_str":"108030240370073602"},"place":null,"source":"web","created_at":"Mon Aug 29 04:23:44 +0000 2011","in_reply_to_user_id":null,"user":{"listed_count":0,"favourites_count":1,"profile_sidebar_fill_color":"FFF7CC","location":"cabuyao,Laguna PHILIPINES","profile_background_tile":false,"lang":"en","profile_link_color":"FF0000","description":"Prudence keeps life safe, but it does not often make it happy.","default_profile_image":false,"default_profile":false,"verified":false,"profile_sidebar_border_color":"F2E195","notifications":null,"time_zone":"Alaska","created_at":"Sun Nov 14 …

我有一个Android应用程序启动TwitterStream与Twitter4j,我正在寻找帮助,如果我不再需要流停止/关闭它.我根据偏好更改启动了流,但需要根据用户操作在我的应用的其他部分停止它.

以下是我启动流的方式,这是我在文档中找到的典型方法:

ConfigurationBuilder cb = new ConfigurationBuilder();

cb.setDebugEnabled(true);

cb.setOAuthConsumerKey(A);

cb.setOAuthConsumerSecret(B);

cb.setOAuthAccessToken(C);

cb.setOAuthAccessTokenSecret(D));

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

    @Override
    public void onDeletionNotice(StatusDeletionNotice arg0) {

    }
    .
    .   
    .

};
FilterQuery fq = new FilterQuery();
fq.follow(new long[]{X});

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

任何帮助将不胜感激,谢谢!

我正在使用ExTwitter库,并希望能够偶尔杀死对流API的调用以更改参数.

我当前的代码看起来像这样:

for tweet <- ExTwitter.stream_filter(track: terms) do
    process_tweet tweet
end

有什么我可以做的表明我不想要更多的消息吗？

我正在使用Twitter4j访问流API。我正在使用follow，以获取与一组用户相关的流。我的问题基本上可以归结为：给定流中的一个转发（我有转发的ID和用户的ID），如何找到：

1. 原始推文的用户ID
2. 原始tweet的tweetID

我不认为API公开了这个吗？

我需要从一个Twitter帐户流式传输推文,但我不确定我做错了什么.使用"跟踪"时,流可以正常工作(流媒体趋势主题).但是,当我使用"跟随"时代码中断.

我正在使用ntwitter模块.

这是代码:

var twitter = require('ntwitter');

var twit = new twitter({
  consumer_key: 'deleted',
  consumer_secret: 'deleted',
  access_token_key: 'deleted',
  access_token_secret: 'deleted'
});


twit.stream('statuses/filter', { follow:'@tbottt' }, function(stream) {
    stream.on('data',function(data){
      console.log(data);
    });
});

我收到这个错误

Error: Uncaught, unspecified 'error' event.
    at EventEmitter.emit (events.js:68:15)
    at ClientRequest.Twitter.stream (F:\Dropbox\work\socketio\node_modules\ntwitter\lib\twitter.js:251:14)
    at ClientRequest.EventEmitter.emit (events.js:88:17)
    at HTTPParser.parserOnIncomingClient [as onIncoming] (http.js:1455:7)
    at HTTPParser.parserOnHeadersComplete [as onHeadersComplete] (http.js:111:23)
    at CleartextStream.socketOnData [as ondata] (http.js:1366:20)
    at CleartextStream.CryptoStream._push (tls.js:492:27)
    at SecurePair.cycle (tls.js:846:20)
    at EncryptedStream.CryptoStream.write (tls.js:227:13)
    at Socket.ondata (stream.js:38:26)

我正在使用twit node.js模块用于twitter api,我试图通过使用他们的id来获取用户列表的状态流但是当我运行脚本时它出现以下错误

Error: Bad Twitter streaming request: 406

以下是代码

var http = require('http')
, server = http.createServer(app)
, Twit = require('twit')
server.listen(4040);

var T = new Twit({
consumer_key:           'abc'
, consumer_secret:      'abc'
, access_token:         'abc'
, access_token_secret:  'abc'
});
var watchList = ['@Kashmala_Tariq', '@Mushahid', '@Fbuttho'];
var stream = T.stream('statuses/filter', { follow : watchList });

stream.on('tweet', function (tweet) {
console.log('@'+tweet.user.screen_name + ':::' + tweet.text);
});

这是api的链接我正在使用 twit twit-module

请指导我在这个剧本中做错了什么

在从火花1.6.2迁移到火花2.0.0期间出现了包org.apache.spark.streaming.twitter已被删除,并且Twitter流不再可用以及依赖

<dependency>
  <groupId>org.apache.spark</groupId>
  <artifactId>spark-streaming-twitter_2.11</artifactId>
  <version>2.0.0</version>
</dependency>

任何人都可以建议如何在新火花中推广Twitter流？