Azure Cosmos DB授权头缺失：messageToCosmos函数报错排查

我在测试项目里的messageToCosmos函数可以正常运行，但在当前项目调用时抛出以下错误：

{ Error: Required Header authorization is missing. Ensure a valid Authorization token is passed. ActivityId: 1250064f-f72d-4b73-adb7-4f2bcd91e778, Microsoft.Azure.Documents.Common/2.7.0 }

我已经配置了Azure Cosmos DB的端点与密钥，相关代码和配置文件如下：

主项目代码 #

const express = require('express')
const bodyParser = require('body-parser')
const mongoose = require('mongoose')
require('dotenv').config();
var fs = require('fs');
var https = require('https');
var http = require('http');
const app = express();
const dbString = 'mongodb://localhost:27017/blue-isSecure';
const messageRoute = require('./routes/messages')
const multer = require('multer');
const path = require('path');
const cors = require('cors')
const cron = require('node-cron')
// cosmos
const CosmosClient = require('@azure/cosmos').CosmosClient;
const config = require('./config')
const endpoint = config.endpoint;
const cosmosKey = config.key;
const client = new CosmosClient({ endpoint, cosmosKey });
const databaseId = config.database.id
const containerId = config.container.containerMessages

const fileStorage = multer.diskStorage({
 destination:(req, file, cb ) =>{
 cb(null,'files')
 },
 filename:(req, file, cb) => {
 cb(null, file.originalname)
 }
})

app.use(bodyParser.json())
app.use(bodyParser.urlencoded({extended:false}))
app.use(multer({storage:multer.memoryStorage()}).single('file'))
app.use('/files', express.static(path.join(__dirname,'files')))
app.use('/blue-isSecure',messageRoute)

async function messageToCosmos(itemBody) {
 const { item } = await client.database(databaseId).container(containerId).items.upsert(itemBody);
 console.log(`Created family item with id:\n${itemBody.id}\n`);
};

messageToCosmos({message:'hey buddy'}).catch(err =>console.log(err))

mongoose.connect(dbString,{useNewUrlParser:true, useUnifiedTopology:true})
 .then(connect =>{
 app.listen(process.env.PORT || 2020)
 console.log('listening')
 })
 .catch(err => {
 console.log(err)
 })

配置文件 (./config.js) #

var config = {}
config.endpoint = "https://bluecosmosdb.documents.azure.com:443/";
config.key = "j2EFBfUe1GQpd5Sewv0LXUUluhrjdOuQ0w14JkJYSe4ISVkN9SBBPxq8wynW6bs7QCicbYsB6DaAfVd5Q1K6Nw==";
config.database = { id: 'blueSecures' }
config.container = { containerMessages: 'messages' }
module.exports = config;

请帮忙排查这个授权头缺失的问题。

我帮你排查出这个授权头缺失问题的核心原因，以及对应的修复步骤：

1. 最关键的问题：CosmosClient 密钥参数名错误 #

在 @azure/cosmos SDK 的构造函数配置中，授权密钥对应的参数名是**key**，但你代码里用了自定义的cosmosKey变量名来传递。SDK无法识别这个参数，导致请求时没有带上必要的授权头，直接抛出了"authorization is missing"的错误。

修改这一段代码：

// 原代码
const cosmosKey = config.key;
const client = new CosmosClient({ endpoint, cosmosKey });

改为：

// 修复后
const key = config.key;
const client = new CosmosClient({ endpoint, key });
// 或者更简洁的写法
// const client = new CosmosClient({ endpoint: config.endpoint, key: config.key });

2. 额外的验证步骤 #

除了参数名问题，你可以再确认以下几点，避免其他潜在问题：

• 检查 config.endpoint 是否是 Azure 门户中复制的完整端点（必须包含 https:// 和端口 :443）
• 确认 config.key 是有效的 Cosmos DB 账户密钥（主密钥或只读密钥均可，注意不要包含多余空格）
• 核对 databaseId 和 containerId 是否与 Azure 中创建的数据库、容器名称完全一致（Cosmos DB 的名称是大小写敏感的）

3. 优化函数调用时机（可选） #

当前你在代码最外层直接调用messageToCosmos，这会在 Express 应用初始化、MongoDB 连接完成前就执行。虽然这不是授权错误的原因，但可能引发时序问题。建议把调用移到 MongoDB 连接成功的回调里：

mongoose.connect(dbString,{useNewUrlParser:true, useUnifiedTopology:true})
 .then(connect =>{
 console.log('Connected to MongoDB')
 // 确保MongoDB连接成功后再操作Cosmos DB
 messageToCosmos({message:'hey buddy'}).catch(err =>console.log(err))
 app.listen(process.env.PORT || 2020)
 console.log('listening')
 })
 .catch(err => {
 console.log(err)
 })

完成这些修改后，重新启动项目，授权头缺失的问题应该就能解决了。

内容的提问来源于stack exchange，提问作者Amaan Imtiyaz