听起来像是轮询或长轮询。我会把它放在一个单独的模块中，并在新数据上引发一个事件。
我没有测试这段代码，所以你可能需要修复一些东西，但它是一般的想法。

// in poll.js                                    
var events = require('events');                  
var request = require('request');                

function Checker(url) {                          
  var self = this;                               

  function resp(e,r,body) {                      
    if (body.indexOf('new data'===0)) {          
      self.emit('newdata', {data:body.substr(10)});                                                  
    }                                            
    setTimeout(function(){self.check(url, resp);}, 1000);                       
  }                                              

  this.url = url;                                

  this.check = function(url) {                   
    request.get(url, resp);                      
  }                                              

  this.check(url);      

}                                                

Checker.prototype.__proto__ = events.EventEmitter.prototype;

module.exports = Checker;                        

// in server.js                                  
var Checker = require('./poll.js');              
io.on('connection', function (socket) {          
  var checker = new Checker('http://theurl.com/'+socket.id);                                          
  checker.on('newdata', function(data) {         
     socket.emit('newdata', data );                 
  });                                            
});

一个典型的死循环轮询node.js中的某个端点将涉及一个setTimeout()，它是在完成处理程序中从上一个调用中调用的。因此，由于您没有提供真正的代码，下面是它如何工作的概述：

function makeCall(arg1, arg2, arg3) {
    request(...., function(err, data) {
        if (err) {
           // error handling here
        } else {
           // process data here
           // start next API call after some timeout
           setTimeout(function() {
               makeCall(arg1, arg2, arg3);
           }, 5000);
        }
    });
}

您可以使用axios和setTimeout()函数调用端点。注意：要确保上一个请求已完全处理，可以使用标志
例如：

let flag=true;
if(flag==true){
setTimeout(()=>{
    axios.post(endpointUrl,reqBody);
},timeout)
}

const endpointName=async (req,res)=>{
//do something with req body and send response.
//make flag false till your processing get complete
//as soon as it gets complete and you want to get the endpoint called again make the flag true.
}