异步循环不遵守异步

Question

我对一个异步函数有点拘泥于此。

我要完成的是创建一个batchProcessing函数(batchGetSubs)，它将循环访问一组文件，读取一个ID，然后发出一个API请求，等待一个响应（问题），然后用格式化的数据写入一个新文件。

问题--我尝试了异步和等待，以及推送承诺和尝试使用承诺.所有这些都是为了等待承诺的解决，但没有成功。当前的行为是，在API调用实际返回所有数据之前，我获取Promission.all部分中的所有console.logs。我引用了这些文章作为参考：

• javascript for循环内部的异步进程
• 用Axios承诺全部
• JavaScript承诺将值推入数组（仅从函数或外部？）

密码-

async function batchGetSubs(data, command) {
    console.time('batchGetSubs')
    iteration = 1;
    let dataArray = []; promises = [];

    // LOOP THROUGH FILES, THEN GET TENANTS BY SUB
    for (i = iteration; i < totalIterations; i++) {
        let msIds = await loopAndDump(iteration);

        // LOOP THROUGH TENANTIDS AND GET SUBSCRIPTIONS
        msIds.map(async item => {
            let newRecord = await getSubsByTenantId(item);
            promises.push(await newRecord);
        });
        }
        Promise.all([promises]).then(() => { // FIXME: WHY IS THIS NOT WAITING FOR ALL RESPONSES?
            console.log(p1SubscriptionArray),
            console.timeEnd('batchGetSubs')
        });
    }



async function getSubsByTenantId(msTenantId) {
    let newRecord; let subscriptionArray = [];
    let bearerToken = p1BearerToken;
    let totalSubs = 0;
    const subIdConfig = {
        method: 'get',
        url: ``,
        headers: { 'Authorization': bearerToken }
    }
    await delay();
    await axios(subIdConfig)
        .then(async res => {
            console.log('AXIOS RESPONSE', res.data);
            if (res.data.items) {
                let subItems = res.data.items;
                console.log('^^^^^^^^^^^^^^^^^^', res.data.items)
                // LOOP THROUGH AND ADD TO SUBSCRIPTION ARRAY
                subItems.map(async subscription => {
                    if (subscription.friendlyName) {
                        totalSubs++;
                        subscriptionArray.push(subscription.friendlyName);
                    }
                });
                newRecord = { "tenantId": msTenantId, "totalSubs": totalSubs, "subscriptionFriendlyName": subscriptionArray };
            } else {
                // NO SUBS
                newRecord = { "tenantId": msTenantId, "totalSubs": totalSubs, "subscriptionFriendlyName": ['NONE'] };
                let statusCode, errorMessage;
                if (error && error.response === undefined) { // GETTING STATUS -4039 or -4077 INSTEAD OF 429 WHEN CHECKING SUBS. FORCE A RESEND.
                    if (error.errno && error.errno === -4039 || error.errno && error.errno === -4077) statusCode = 429; errorMessage = error.code;
                } else {
                    statusCode = error.response.status;
                    errorMessage = error.response.statusText;
                }
                console.error('ERROR:: SUBIDCONFIG SECTION THROWING ERROR: ', statusCode, portal, errorMessage);
                // SORT NON-200 CALLS BASED ON STATUS CODE
                switch (statusCode) {
                    case 403:
                        status403.push('subs', newRecord);
                        break;
                    case 404:
                        status404.push('subs', newRecord);
                        erroring = true;
                        break;
                    case 429:
                        status429.push('subs', newRecord);
                        erroring = true;
                        break;
                    default:
                        statusOther.push('subs', newRecord)
                        erroring = true;
                        break;
                }
            }
        })
        .catch(err => {
            newRecord = { "tenantId": msTenantId, "totalSubs": totalSubs, "subscriptionFriendlyName": ['NONE'] };
            console.error('ERROR: REQUEST IN GETSUBSBYTENANTID(): ', err)
        })
        .then(res => {
            console.log('DO WE HAVE ANY INFORMATION? ', newRecord);
            p1SubscriptionArray.push(newRecord);
            resolve();
        });
}

Answer 1

你做一个等待然后在同一时间。你做一个承诺/然后或等待/异步

做

async function getSubsByTenantId(msTenantId) {
    let newRecord; let subscriptionArray = [];
    let bearerToken = p1BearerToken;
    let totalSubs = 0;
    const subIdConfig = {
        method: 'get',
        url: ``,
        headers: { 'Authorization': bearerToken }
    }
    await delay();
    const r = await axios(subIdConfig)
    const reponse = r.data
    console.log(response)
}

如果要尝试catch,请执行以下操作：

async function getSubsByTenantId(msTenantId) {
    let newRecord; let subscriptionArray = [];
    let bearerToken = p1BearerToken;
    let totalSubs = 0;
    const subIdConfig = {
        method: 'get',
        url: ``,
        headers: { 'Authorization': bearerToken }
    }
    await delay();
    let r
    try {
      r = await axios(subIdConfig)
    } catch (error) {
     console.log(error)
    }
    const reponse = r.data
    console.log(response)
}

Answer 2

我只检查了第一个函数,您在其中提出了您的问题：

为什么这不是等待所有的回应呢？

有几个原因：

>

调用promise.all时，promise数组仍然为空。这是因为您只在await之后执行push，因此push是异步发生的（稍后阅读）。

即使填充了promission数组，它也不会包含promissions对象，而是解析值（即newrecord值）

即使promission是promissions的数组，您也没有将该数组正确传递给promission.all:您将该数组包装在另一个数组中，然后该数组只有一个条目，而该条目不是promission，而是一个数组。

与您的问题无关，但：

>

请养成显式声明所有变量的习惯。您没有为迭代、承诺或i执行此操作。

仅在使用返回值执行某些操作时使用.map。对于纯迭代，请使用.foreach或For。在这种情况下，可以使用返回值扩展promission数组。

如果您打算调用BatchGetSubs并需要知道何时完成所有操作，那么请确保它返回一个有用的承诺:returnpromise.all()

以下是该函数的建议更正：

async function batchGetSubs(data, command) {
    console.time('batchGetSubs')
    let iteration = 1; // Declare!
    let dataArray = []; 
    let promises = []; // declare

    // declare i
    for (let i = iteration; i < totalIterations; i++) {
        let msIds = await loopAndDump(iteration);

        // Use the return value of the map method. No need for async callback
        promises.push(...msIds.map(item => {
            // Get the promise, not the resolved value, as that will come too late:
            return getSubsByTenantId(item);
        }));
    }
    // promises is already an array; don't make it an array of arrays.
    // And: return the resulting promise: it may be useful to the caller.
    return Promise.all(promises).then(() =>  {
        console.log(p1SubscriptionArray),
        console.timeEnd('batchGetSubs')
    });
}