【发布时间】:2022-10-17 19:41:38
【问题描述】:
我正在为不和谐设计一个 twitter 集成,并且通过调用搜索最近的推文遇到了速率限制问题。我正在研究流式传输,但无法弄清楚如何流式传输多个用户(在命令中添加)。我目前正在使用此代码,它对一个用户非常有用,但鉴于每个流的规则都保持不变,我看不到一种轻松运行单独实例的方法:
const { ETwitterStreamEvent, TweetStream, TwitterApi, ETwitterApiError } = require('twitter-api-v2');
const client = new TwitterApi(process.env["BEARER_TOKEN"]);
async function startStream(userName){
const stream = await client.v2.searchStream();
await client.v2.updateStreamRules({
add: [
{ value: `from:${userName}`, tag: userName },
],
});
stream.on(
ETwitterStreamEvent.ConnectionError,
err => console.log('Connection error!', err),
);
stream.on(
ETwitterStreamEvent.ConnectionClosed,
() => console.log('Connection has been closed.'),
);
stream.on(
ETwitterStreamEvent.Data,
eventData => console.log(eventData),
);
stream.autoReconnect = true;
}
有没有办法同时为不同的用户运行多个流?
【问题讨论】:
标签: node.js twitter-streaming-api twitter-api-v2