定义无限循环以从API读取数据并与数据库进行比较的最佳位置

如何解决定义无限循环以从API读取数据并与数据库进行比较的最佳位置

我有一个程序想要从API读取数据并将该数据与数据库中存储的数据进行比较。如果存在某些条件，则从数据库中删除数据并将数据发送给函数。 在此示例中，数据库和API对我而言并不重要，但是如果您想知道，我正在与 “ node-binance-api”，Redis数据库和Node.js。

REdis_PORT = process.env.PORT || 6379;
    redisClient = createClient(this.REdis_PORT);
    binance.futuresMiniTickerStream((miniTicker) => {
      miniTicker.forEach((_array) => {
        _array.forEach((selectedPair) => {
          redis.ZRANG(`binance-future-${selectedPair.symbol}`,(obj) => {
            obj.forEach(item => {
                item = JSON.parse(item);
                if (item.targetPrice > item.firstPrice && selectedPair.close >= item.targetPrice || item.targetPrice < item.firstPrice && selectedPair.close <= item.targetPrice) {
                  redisClient.ZREMRANGEBYscore(`binance-future-${selectedPair.symbol}`,item.targetPrice,() => {
                    console.log("Item Deleted");
                  })
                }
              });
            });
          });
        });
      });
    }

如何优化这段代码？ 此外，对于某些优化操作，我想使用RabbitMQ将代码分发给某些工作人员，在此项目之前，我曾使用RabbitMQ，但是任何想法，我都很高兴阅读。