mongodb JS函数进行API调用

bwleehnv 于 2023-06-29 发布在 Go

关注(0)|答案(2)|浏览(127)

我有以下代码。
我尝试进行API调用（检索），传递since（obj.since），因此，每次我进行调用时，API都不会检索所有数据。然而，到目前为止，我还没有找到从数据库上的最后一条记录中获取since的方法。

var express = require("express");
var article = require("../models/article");
var request = require('request');
article.findOne({}, {since:1, _id:0}, { sort: { 'since' : -1 } }, function (err,obj) { 
         var **dataString** = `'{"consumer_key":"XXXXX", "access_token":"XXXXXXX", "since":"${obj.since}"}'`;
});
var options = {
    url: 'https://xxxxxxxxx.com/v3/get',
    method: 'POST',
    headers: headers,
    body: **dataString**     
    }
function callback(error, response, body) {
    if (!error && response.statusCode == 200) {
        let package = JSON.parse(body);
        for(var attributename in package.list){
            var title = package.list[attributename]["given_title"] ;
            var url = package.list[attributename]["given_url"] ;
            var newArticle = {title: title, url: url, since: since}
            article.create(newArticle, function(error, newlyCreated){
            if(error){
                console.log(error);
            } else {
                console.log(newlyCreated);
            }
        });
    }
    }
    else {
        console.log(error);
    }
};;
request(options,callback)

如何通过API调用从数据库（MongoDB）获取obj.since并将其传递给对象（选项）？

mongodb

来源：https://stackoverflow.com/questions/59828840/js-functions-to-make-an-api-call

2条答案

按热度按时间

dnph8jn41#

你正在for循环中执行异步回调风格的操作，这导致了这个问题。我会改变一些事情

将findOne更改为在末尾有exec，以便它返回promise
article.create已经返回了一个承诺，如果没有指定回调。
将request转换为promise样式。
使用for..of循环进行异步操作。

代码如下所示

var express = require("express");
var article = require("../models/article");
var request = require('request');
function hitApi(dataString) {
  return new Promise((resolve, reject) => {
    var options = {
      url: 'https://xxxxxxxxx.com/v3/get',
      method: 'POST',
      headers: headers,
      body: dataString    
    }
    request(options, error, response, body => {
      if (err) {
        reject(err);
      }
      resolve(body);
    });
  });
}
async function perform() {
  const dataString = await article.findOne({}, {since:1, _id:0}, { sort: { 'since' : -1 } }).exec();
  const response = await hitApi(dataString);
  const package = JSON.parse(response.body);
  for (const attributename of package.list) {
      var title = package.list[attributename]["given_title"] ;
      var url = package.list[attributename]["given_url"] ;
      var newArticle = {title: title, url: url, since: since}
      const newlyCreated = await article.create(newArticle);
      console.log(newlyCreated);
  }
}