我通过Heroku使用Node.js运行了一个Discord机器人。我一直在实现Twitter API，以便从我们的一些频道中的一些帐户发布推文，但流在一段时间后偶尔崩溃。我知道我没有达到速率限制，而且据我所知，尽管错误说明了这一点，但并没有多个连接在运行。这是我在日志中看到的错误：

Rules: {
   meta: {
   sent: '2022-08-25T17:55:50.381Z',
   summary: { created: 0, not_created: 0, valid: 0, invalid: 0 }
  }
}
/app/node_modules/twitter-v2/build/TwitterError.js:26
return new module.exports(`${json.title}: ${json.detail}`, null, json.type);
TwitterError: ConnectionException: This stream is currently at the maximum allowed connection limit.

这是我在流中使用的代码：

var T = new Twit({
    bearer_token: process.env.BEARER_TOKEN,
    timeout_ms: 60*1000,
    strictSSL: true
})

async function listenForever(streamFactory, dataConsumer) {
      for await (const { data } of streamFactory()) {
        dataConsumer(data);
      }
      listenForever(streamFactory, dataConsumer);
  }
  
async function  setup () {
    const endpointParameters = {
        'tweet.fields': ['text'],
        'expansions': [ 'author_id'],
        'media.fields': [ 'url' ]
    }
    try {
      console.log('Setting up Twitter....')
      const body = {
        "add": [
          // {'value': 'from:account'},
          // {'value': 'from:account'},
          // {'value': 'from:account'},
          // {'value': 'from:account'}
        ]
        // "delete": {
            // ids: [""]
        // }
      }
      const r = await T.post("tweets/search/stream/rules", body);
      console.log("Rules:", r);
  
    } catch (err) {
      console.log(err)
    }
  
    listenForever(
      () => T.stream('tweets/search/stream', endpointParameters),
      (data) => sendMessage(data)
    );
}