1

我使用 promise all 来发送多个 promise，我得到了这个错误

429 - {“错误”：{“代码”：“TooManyRequests”，“消息”：“请求太多”}}

我有数据列表，我按 10 组分组数据，然后我为每个人发送通知

 await Promise.all(usersList.map(usersTokens=> {

                    return sendPush(heading, content,usersTokens, platform).catch((e) => {
                        console.error(e)
                        errors.push({ e, android })
                    })
                }))

发送推送功能

import * as rp from 'request-promise'
export const sendPush = (title="",secondTitle,tokens,platform) => {


let message = {
    notification_content : {
        name:title,
        title : secondTitle,
        body : secondTitle,

     },
       notification_target : {
       type : "devices_target",
       devices : tokens
     },
   }

 var headers = {
    "Content-Type": "application/json; charset=utf-8",
    "X-API-Token": 'XXXXXXXXXXXXXXXXXXXXXXXXXXX'
};

var options = {
    uri: `https://api.appcenter.ms/v0.1/apps/XXXXXXXXXX/${platform}/push/notifications`,
    method: "POST",
    headers: headers,
    body: message,
    json: true
}

  return rp(options)

}

4

1 回答 1

1

我按 10 组对数据进行分块

但是您仍然同时请求所有块。因此分块就没那么有意义了。在处理下一个之前，Promise.all您应该使用循环和每个块，而不是使用：await

 const result = [];

 for(const userTokens of userList) {
   try {
     result.push(await sendPush(heading, content,usersTokens, platform));
   } catch(e) {
     console.error(e)
     errors.push({ e, android })
  }
}

如果这对于 API 来说仍然太快，您可以延迟循环

于 2018-07-05T07:12:57.627 回答