1

我正在使用以下两个文件从两个 API 获取数据。请在下面找到我的最小可行示例：

poloniex.js

const Poloniex = require('poloniex-api-node')
const poloniex = new Poloniex()

async function getExchangeTicker() {
  poloniex.returnTicker((err, ticker) => {
    if (err) {
      console.log(err.message)
    } else {
      //console.log(ticker)
      return ticker
    }
  })
}

module.exports = {
  getExchangeTicker,
}

cctx.js

const ccxt = require ('ccxt')

async function getExchangeTicker() {
  const bitfinex = new ccxt.bitfinex({ verbose: true })  
  const data = await bitfinex.fetchTicker()
  return data
}

module.exports = {
  getExchangeTicker,
}

调度程序.js

const exchangePoloniex = require('../exchange/poloniex')
const exchangeCCTX = require('../exchange/cctx')

async function getAllTickers() {
  const exchanges = [
    exchangePoloniex,
    exchangeCCTX,
  ]

  let res
  exchanges.forEach((exchange) => {
    res = exchange.getExchangeTicker()
  })
  return res
}

async function runScheduler() {
  let res
  setInterval(() => {
    this.res = getAllTickers()
  }, 3000)
  console.log("res: " + res)
  return res
}

runScheduler()

我正在运行一个调度程序来汇集这些文件中的数据，但只能res: undefined返回。

关于如何从这两个 API 中正确获取数据的任何建议？

我非常感谢您的回复！

4

1 回答 1

2

我不知道您正在访问的两个 API，所以我无法真正判断您来自 poloniex.js 或 cctx.js 的代码是否良好 - 我假设您可以通过 console.logs 等告诉您正在获取您分别需要的 API 数据。

但是我可以在您的 scheduler.js 文件中看到一些逻辑问题：

  1. 在getAllTickers中，您的.forEach循环会覆盖res每次迭代，因此只有最后一个结果可见。
  2. 因为它是一个async函数，所以getAllTickers返回一个 Promise。您需要使用.then或类似的东西来返回它。
  3. 在 setInterval 有机会执行之前，console.log 和返回runScheduler完成，即使是一次，所以没有可用的数据。

我认为以下设置可能是您想要的：

const exchangePoloniex = require('../exchange/poloniex')
const exchangeCCTX = require('../exchange/cctx')

async function getAllTickers() {

  let updatedTickers = []
  updatedTickers[0] = await exchangePoloniex.getExchangeTicker()
  updatedTickers[1] = await exchangeCCTX.getExchangeTicker()

  return updatedTickers
}

function runScheduler() {
  let tickers
  setInterval(() => {
    tickers = getAllTickers()
    console.log(tickers) // tickers is a promise at this point

    tickers.then((data) => {
        console.log(data) // should be the data returned from your apis
        // store the data in your db
    })
  }, 3000)
}

runScheduler()

请注意，runScheduler不必是异步的，因为您没有对返回值做任何事情 - 所有工作都在setInterval回调中

如果您需要提供此数据以响应浏览器请求，则可以从您的数据库中获取它，知道它已在最后 3 秒内更新。

于 2017-11-05T17:43:14.900 回答