Gmail API批量获取指定ID邮件遇401认证缺失错误求助

我通过Gmail API发起批量请求，传入包含邮件ID的messageList，调用自定义函数getGmailMessagesBatch获取指定ID的Gmail邮件，但解析响应时收到401错误，提示请求缺少必要的OAuth 2访问令牌等认证凭证。

相关代码 #

传入的messageList包含待获取的邮件ID，自定义函数代码如下：

function getGmailMessagesBatch(oauth2Client, messagesList) {
    var batchBody = [];
    var indReq = '';
    if (oauth2Client && oauth2Client.credentials && oauth2Client.credentials.access_token) {
        /*Generating the request body for the batch request
        according to gmail api docs for batching multiple api calls into one request
        each request should a part of the request body, so doing that below
        refer to gmail api docs for details info*/

        _.each(messagesList, function(eachMessage) {
            indReq = '';
            indReq = "--request_boundary\n" +
                "Authoriz
            ation: Bearer "+oauth2Client.credentials.access_token+"\
            n "+
                "Content-Type: application/http\n\n" +
                "GET /gmail/v1/users/" + data.userEmail + "/messages/" + eachMessage.id + "\n";
            batchBody.push(indReq);
        })
        batchBody.push("--request_boundary--\n");
        batchBody = batchBody.join('\n');
        //Sending the batch request
        rp({
                uri: 'https://www.googleapis.com/batch/gmail/v1',
                method: 'POST',
                headers: {
                    "content-type": "multipart/mixed; boundary=request_boundary"
                },
                body: batchBody,
                resolveWithFullResponse: true
            })
            .then(function(response) {
                /*The response is stringified & the response to each of the api calls present
                in the batch request is seperated by a boundary which is present in the content
                type header of the response,therefore we need to parse the response to
                obtain the actual data*/
                var parsedResponse = parseBatchResponse(response);
                return cb(null, parsedResponse);
            })
            .catch(function(error) {
                sails.log.error('Error in getting messages async in eachseries', error, data);
                return cb('Unexpected error!');
            })
    } else {
        sails.log.error('Access token missing to sync emails using gmail api', data);
        return cb('Authorization failure!');
    }
}

错误信息 #

解析响应时收到的401错误详情：

{
  "error": {
    "code": 401,
    "message": "Request is missing required authentication credential. Expected OAuth 2 access token, login cookie or other valid authentication credential. See https://developers.google.com/identity/sign-in/web/devconsole-project.",
    "errors": [
      {
        "message": "Login Required.",
        "domain": "global",
        "reason": "required",
        "location": "Authorization",
        "locationType": "header"
      }
    ],
    "status": "UNAUTHENTICATED",
    "details": [
      {
        "@type": "type.googleapis.com/google.rpc.ErrorInfo",
        "reason": "CREDENTIALS_MISSING",
        "domain": "googleapis.com",
        "metadata": {
          "service": "gmail.googleapis.com",
          "method": "caribou.api.proto.MailboxService.GetMessage"
        }
      }
    ]
  }
}

问题修复方案 #

1. 修复Authorization头的换行错误 #

代码中Authorization字段被错误拆分成两行（Authoriz ation），导致认证头无法被识别。修正后代码：

indReq = "--request_boundary\n" +
    "Authorization: Bearer "+oauth2Client.credentials.access_token+"\n" +
    "Content-Type: application/http\n\n" +
    "GET /gmail/v1/users/" + data.userEmail + "/messages/" + eachMessage.id + "\n";

2. 确认data.userEmail的有效性 #

确保data.userEmail已正确传入函数，若请求当前授权用户的邮件，可直接使用me替代邮箱地址，避免变量未定义问题：

"GET /gmail/v1/users/me/messages/" + eachMessage.id + "\n";

3. 规范批量请求的边界格式 #

• 子请求开头的边界--request_boundary后直接换行，无需额外格式
• 结束边界--request_boundary--无需添加多余换行，确保格式符合HTTP批量请求规范
• 子请求的HTTP方法行末尾保证正确换行

4. 添加令牌过期检查 #

即使令牌存在，也可能已过期，建议在请求前验证并刷新：

if (oauth2Client.isTokenExpiring()) {
  oauth2Client.refreshAccessToken((err, tokens) => {
    if (!err) {
      // 刷新成功后重新发起批量请求
      getGmailMessagesBatch(oauth2Client, messagesList);
    }
  });
  return;
}

5. 改用官方客户端库（推荐） #

手动构造批量请求容易出错，使用Google官方Node.js客户端库可自动处理认证和请求格式，简化开发：

const { google } = require('googleapis');
const gmail = google.gmail('v1');

async function getGmailMessagesBatch(oauth2Client, messagesList) {
  const batch = gmail.newBatchRequest();
  
  messagesList.forEach(msg => {
    batch.add(gmail.users.messages.get({
      auth: oauth2Client,
      userId: 'me',
      id: msg.id
    }));
  });

  try {
    const responses = await batch;
    return responses;
  } catch (err) {
    sails.log.error('批量请求失败:', err);
    throw err;
  }
}

内容的提问来源于stack exchange，提问作者Yashwant Yadav