Tag: twitter streaming api

在Twitterstream中没有收到DM

我有一个具有以下权限的应用程序:“读取,写入和访问直接消息”。 使用Twitterstream,我收到所有其他事件/数据,如推文,取消关注等,但不direct_message。 与我的应用程序相关的帐户是跟随消息发送用户,反之亦然。 我也可以通过wwwvalidation消息是否通过。 该应用程序帐户只有一个追随者是我从哪里发送的帐户。 我正在使用twit nodejs库: https : //github.com/ttezel/twit#event-direct_message stream.on('direct_message', function(direct_message) { console.log('direct_message',direct_message); } build议做什么?

ntwitter:在Xcallback之后停止监听stream事件

//完全新到node.js 我使用ntwitter来聆听twitter状态。 Xcallback被调用后,如何停止监听? var twittsCounter = 0; twit.stream('statuses/filter', {track:['cool','awesome','fuck yeah!']}, function(stream) { stream.on('data', function (tweet) { twittsCounter += 1; console.log(twittsCounter + ":" + tweet.text); if (twittsCounter > 100){ //stop listening? } });

Nodejs + Twitter Streaming API无法跟踪某些单词

我正在尝试使用Nodejs来捕捉特定单词的推文。 使用twitter模块,我写道: var util = require('util'), twitter = require('twitter'); var twit = new twitter({ consumer_key: '***', consumer_secret: '***', access_token_key: '***', access_token_secret: '***' }); console.log('Bot ON!'); twit.stream('statuses/filter', {'track': ['love']}, function(stream) { stream.on('data', function(data) { console.log(util.inspect(data)); }); stream.on('error', function(err){ console.log(err.message); }); }); 当我执行这个代码时,我可以跟踪“爱”这个词。 但是,如果我改变了像“hyjhuolup”,stream媒体不显示任何鸣叫。 我在代码中join了“hyjhuolup”这个词,在我的账户中发送了一条消息(与节点使用的账户不同),没有任何反应。 我真的不知道为什么。 我在其他图书馆也有同样的问题,比如“twit”。 任何人都知道我能做什么? 谢谢。 编辑1:我已经试试这个: 无法检索基于与nodejs哈希标签鸣叫,但没有成功。

无法销毁node.js中的Twitterstream

我正在尝试与Socket.io一起使用NPM twitter。 stream.destory()函数不起作用。 var util = require('util'); var twitter = require('twitter'); var twit = new twitter({ consumer_key: '', consumer_secret: '', access_token_key: '', access_token_secret: '' }); var currentTwitStream; hashtags = []; module.exports = function (io) { io.sockets.on('connection', function (socket) { console.log('A new user connected!'); socket.on('data', function(data){ hashtags.push('#' + data.hashtag); hashtags.forEach(function(entry) { console.log(entry); }); if(currentTwitStream) currentTwitStream.destroy(); twit.stream('statuses/filter',{track:hashtags.join(',')},function(stream){ […]

按用户描述过滤推文

你好,我需要过滤所有的用户描述匹配特定的短语(比如,演员)的鸣叫。 我能够过滤所有与短语相匹配的推文,但不能过滤那些用户描述中包含短语的推文。 任何想法如何做到这一点? 我正在使用TwitterstreamAPI。 这是我的代码直到现在看起来像.. var Twit = require ('twit') var Twits = new Twit ({ consumer_key : '….', consumer_secret: '….', access_token: '….', access_token_secret: '….', timeout_ms : 60*1000 , }) var stream = Twits.stream('statuses/filter' , { track : 'actor', language : 'en' }) //var stream = Twits.stream('statuses/firehose') var array = []; stream.on( 'tweet', function (tweet) […]

如何将请求中的模拟数据返回到Node中的Twitter Streaming API

我有一个连接到Twitter REST和stream媒体API的Node应用程序。 为了testing向REST API发出请求的代码,我可以使用Nock拦截HTTP请求并返回模拟数据,如下所示: var nock = require('nock') var mockData = […] nock('https://api.twitter.com/1.1') .get('/search/tweets.json') .reply(200, mockData) 我的应用程序还连接到stream媒体API端点状态/filter,并对通过stream式API接收的推文执行一些分析。 在Nock的README中,它声明你可以传递一个函数给.query()返回一个stream,但是我一直无法得到这个工作。 如何使用Nock(或其他库,如果有必要)从请求返回模拟数据到这个端点? 理想情况下,我希望能够在我的testing中随时发送推文到stream中,例如: it('should correctly process tweets coming in on the streaming API', () => { var mockTweet = {…} sendMockTweetToStream(mockTweet) …verify that the mock tweet was received and processed })

性能testingTwitter Streaming API消费者

我有一个使用Twitter Streaming API实时使用twitterpost的服务。 我build立了一个连接到stream的后台进程,并将推送到Redis中。 这是用node.js构build的 我需要做的是找出这个过程可以消耗的最大数量的鸣叫。 我需要性能testing这个设置。 什么是testing这个最好的方法? 我需要知道: 它可以处理之前,它可以处理多less鸣叫 当进程不能处理更多的推文时会发生什么 另一个我想这样做的原因是要弄清楚它是否值得使用node.js。 我宁愿用EventMachine代替它。

node.js和socket.io未被捕获的错误

我正在尝试使用ntwitter,node.js和socket.io来访问twitter用户stream。twitter用户stream正常工作,我可以实时获取tweets。tweets使用以下函数显示在控制台中。 console.log(data.text) ; 那么我想推送数据到browser.this可以使用套接字来完成。下面的链接显示了一个简单的node.js客户端的twitetrs公共stream的例子。 http://www.informit.com/articles/article.aspx?p=1947699&seqNum=5 现在同样不适用于我的用户stream.the数据显示在控制台中没有任何问题,但如果我尝试推它到浏览器我得到错误。 Error: Uncaught, unspecified 'error' event. at EventEmitter.emit (events.js:73:15) at EventEmitter.receive (C:\Users\tweeple\Desktop\ho odules\ntwitter\lib\parser.js:41:14) at IncomingMessage.Twitter.stream (C:\Users\prathamesh\ e03\node_modules\ntwitter\lib\twitter.js:266:14) at IncomingMessage.EventEmitter.emit (events.js:96:17) at IncomingMessage._emitData (http.js:359:10) at HTTPParser.parserOnBody [as onBody] (http.js:123:21) at CleartextStream.socketOnData [as ondata] (http.js:13 at CleartextStream.CryptoStream._push (tls.js:526:27) at SecurePair.cycle (tls.js:880:20) at EncryptedStream.CryptoStream.write (tls.js:267:13) 代码是: var app = require('express').createServer(), twitter = require('ntwitter'), […]

Nodejs模块不能按预期在不同的设备上工作

我正在使用twitter streaming api & johnny-five与其他模块http , express和socket.io与arduino uno 我的脚本在笔记本电脑上工作正常。 但我的作品将在平板电脑上。 我有两个平板电脑,两个都有不同的反应。 在hp omni平板电脑上我收到以下错误 另外我有端口COM3 arduino-uno连接,但它显示设备COM1连接 据我所知,这个错误是由于standard firmata firmata在arduino中没有升级引起的。 我已经上传这个程序,它在笔记本电脑上工作正常 在Acer平板电脑我没有收到任何错误程序开始完美罚款没有任何问题,但我没有收到微博与twitter streaming api 我已经跨过多次检查,每次运行时都会在笔记本电脑上运行得非常好,但给出了tablets两个不同的问题 这是我正在使用的代码 var Twitter = require('twitter'); var five = require("johnny-five"); var express = require('express') , app = express() , http = require('http') , server = http.createServer(app) , io = require('socket.io').listen(server); server.listen(8080); // routing […]