nodeJS：如何在另一个异步函数调用的循环中调用异步函数

Question

我试图从另一个异步函数运行的循环中调用一个异步函数。这些函数调用 API，我使用 request-promise 和 nodeJS。

functions.js 文件

const rp = require("request-promise");


// function (1)
async email_views: emailId => {
    let data = {};
    await rp({
       url: 'myapiurl',
       qs: { accessToken: 'xyz', emailID: emailId },
       method: 'GET'
    })
      .then( body => { data = JSON.parse(body) })
      .catch( error => { console.log(error} );

    return data;
};

上面的 JSON 看起来像这样：

...
data:{
   records: [
      {
        ...
        contactID: 123456,
        ...
      },
      {
        ...
        contactID: 456789,
        ...
      }
   ]
}
...

我正在运行一个循环来获取单个记录，其中我得到一个与每个记录相关联的contactID。

// function#2 (also in functions.js file)
async contact_detail: contactId => {
    let data = {};
    await rp({
       url: 'myapiurl2',
       qs: { accessToken: 'xyz', contactID: contactId },
       method: 'GET'
    })
      .then( body => { data = JSON.parse(body) })
      .catch( error => { console.log(error} );

    return data;

};

上述函数将contactId 作为参数，并通过调用另一个API 端点获取该联系人的详细信息。

这两个函数在单独调用时都能正常工作。但我试图在这样的循环中做到这一点：

...
const result = await email_views(99999); // function#1
const records = result.data.records;
...
let names = "";
for( let i=0; i<records.length; i++) {
    ...
    const cId = records[i].contactID;
    const contact = await contact_detail(cId); // function#2
    names += contact.data.firstName + " " + contact.data.lastName + " ";
    ...
}
console.log(names);
...

问题是我只从上面的代码块中得到第一个 contact，即即使我有来自 function#1 的 20 条记录，在我调用 contact_detail 时的循环中（函数#2) 对于每个contactID (cId)，我会获得一次联系方式，即仅针对第一个cId。休息我什么都得不到！

使用nodeJs 实现此目的的正确方法是什么？

更新：

const { App } = require("jovo-framework");
const { Alexa } = require("jovo-platform-alexa");
const { GoogleAssistant } = require("jovo-platform-googleassistant");
const { JovoDebugger } = require("jovo-plugin-debugger");
const { FileDb } = require("jovo-db-filedb");

const custom = require("./functions");
const menuop = require("./menu");
const stateus = require("./stateus");
const alexaSpeeches = require("./default_speech");
const app = new App();

app.use(new Alexa(), new GoogleAssistant(), new JovoDebugger(), new FileDb());

let sp = "";
async EmailViewsByContactIntent() {
    try {
      const viewEmailId =
        this.$session.$data.viewEmailIdSessionKey != null
          ? this.$session.$data.viewEmailIdSessionKey
          : this.$inputs.view_email_Id_Number.value;
      let pageIndex =
        this.$session.$data.viewEmailPageIndex != null
          ? this.$session.$data.viewEmailPageIndex
          : 1;

      const result = await custom.email_views_by_emailId(
        viewEmailId,
        pageIndex
      );
      const records = result.data.records;
      if (records.length > 0) {
        const totalRecords = result.data.paging.totalRecords;
        this.$session.$data.viewEmailTotalPages = totalRecords;
        sp = `i have found a total of ${totalRecords} following view records. `;
        if (totalRecords > 5) {
          sp += `i will tell you 5 records at a time. for next 5 records, please say, next. `;

          this.$session.$data.viewEmailIdSessionKey = this.$inputs.view_email_Id_Number.value;
          this.$session.$data.viewEmailPageIndex++;
        }

        for (let i = 0; i < records.length; i++) {
          const r = records[i];

          /* Here I want to pass r.contactID as contactId in the function contact_detail like this: */

          const contact = await custom.contact_detail(r.contactID);
          const contact_name = contact.data.firstName + " " + contact.data.lastName;

         /* The above two lines of code fetch contact_name for the first r.contactID and for the rest I get an empty string only. */

          const formatted_date = r.date.split(" ")[0];
          sp += `contact ID ${spellOut_speech_builder(
            r.contactID
          )} had viewed on ${formatted_date} from IP address ${
            r.ipAddress
          }. name of contact is, ${contact_name}. `;
        }
        if (totalRecords > 5) {
          sp += ` please say, next, for next 5 records. `;
        }
      } else {
        sp = ``;
      }
      this.ask(sp);
    } catch (e) {
      this.tell(e);
    }
  }

我正在使用JOVO 框架和nodeJS 构建一个alexa 技能。

更新 #2 作为测试，我只返回了contactId，我将其传递给contact_detail 函数，并且在我的第一个UPDATE 下，我将正确的值返回到上述代码。

async contact_detail: contactId => {
   return contactId;
}

似乎即使在获得正确的值之后，该函数还是无法执行。但是，当我从另一个地方调用它时，相同的 contact_detail 函数可以正常工作。只有在循环中不起作用。

可能是什么原因？ 我一定错过了什么，但不知道是什么！

Answer 1

您将 async await 和 promises 混合在一起，这导致您感到困惑。您通常会在给定位置使用其中之一（因为 async await 有效地提供了语法糖，因此您可以避免处理冗长的承诺代码）。

因为您将两者混为一谈，所以您处于一个难以确定行为的奇怪区域。

如果你想使用 async await，你的函数应该是这样的

async contact_detail: contactId => {
  try {
    const body = await rp({
       url: 'myapiurl2',
       qs: { ... }
    });

    return JSON.parse(body);
  } catch(e) {
    console.log(e);
    //This will return undefined in exception cases. You may want to catch at a higher level.
  }
};

或承诺

async contact_detail: contactId => {
    return rp({
       url: 'myapiurl2',
       qs: { ... }
    })
      .then( body => JSON.parse(body))
      .catch( error => { 
         console.log(error);
         //This will return undefined in exception cases. You probably dont want to catch here.
      });
};

请记住，您当前执行该函数的代码将依次执行每个调用。如果您想并行执行它们，则需要稍微不同地调用函数并使用 Promise.all 之类的东西来解析结果。

Answer 2

给你：

...
const result = await email_views(99999); // function#1
const records = result.data.records;
...
let names = "";
await Promise.all(records.map(async record => {
    let cId = record.contactID;
    let contact = await contact_detail(cId);
    names += contact.data.firstName + " " + contact.data.lastName + " ";
});
console.log(names);
...

Answer 3

我将其发布为答案只是因为我需要向您展示一些多行代码作为解决此问题的一部分。不确定这是否能解决您的问题，但这是一个问题。

您的contact_detail() 函数未正确返回错误。相反，它会吃掉错误并使用空对象解决。这可能是导致您的空白名称的原因。它应该直接返回承诺，如果你想记录错误，那么它需要重新抛出。此外，没有理由将其声明为async 或使用await。您可以直接返回承诺。您也可以让 request-promise 为您分割 JSON 响应。

另外，我注意到，您的 .catch() 中似乎存在语法错误，这也可能是问题的一部分。

contact_detail: contactId => {
    return rp({
       url: 'myapiurl2',
       qs: { accessToken: 'xyz', contactID: contactId },
       json: true,
       method: 'GET'
    }).catch( error => { 
        // log error and rethrow so any error propagates
        console.log(error);
        throw error;
    });
};

然后，你会像原来一样调用它（注意你在调用它时仍然使用await，因为它返回一个承诺）：

...
const result = await email_views(99999); // function#1
const records = result.data.records;
...
let names = "";
for( let i=0; i<records.length; i++) {
    ...
    const cId = records[i].contactID;
    const contact = await contact_detail(cId);
    names += contact.data.firstName + " " + contact.data.lastName + " ";
    ...
}
console.log(names);
...