Cosmos DB存储过程批量添加文档项报错排查求助

这个错误我太熟了！本质就是你的存储过程返回了null，但调用端（看起来是.NET代码）期望接收一个System.Int32类型的返回值，类型不匹配直接导致了反序列化失败。我给你一步步拆解修复方案：

1. 先把存储过程的返回值补全 #

Cosmos DB存储过程如果没有明确写return或者用setBody指定返回内容，默认会返回null。而你的调用逻辑应该是在期待一个整数（比如成功插入的条目数），这就撞车了。

给你补全正确的存储过程逻辑，重点是确保最后返回明确的整数：

function spBulkAddStockCountItems(tenantId, stockCountId, stockCountItems) {
    var collection = getContext().getCollection();
    var insertedCount = 0;

    // 递归处理批量插入的函数
    function processNextItem(items) {
        if (items.length === 0) {
            // 全部插入完成，返回成功条数
            getContext().getResponse().setBody(insertedCount);
            return;
        }

        var currentItem = items[0];
        // 给条目补充必要的关联字段（根据你的业务需求调整）
        currentItem.tenantId = tenantId;
        currentItem.stockCountId = stockCountId;
        // 可以手动生成唯一ID，或者让Cosmos自动生成（如果id字段不是必填的话）
        currentItem.id = `${tenantId}-${stockCountId}-${Date.now()}-${insertedCount}`;

        // 尝试插入文档
        var isRequestAccepted = collection.createDocument(
            collection.getSelfLink(),
            currentItem,
            function(err, insertedDoc) {
                if (err) {
                    // 插入出错时，返回错误标识（比如-1），避免返回null
                    getContext().getResponse().setBody(-1);
                    throw err;
                }
                insertedCount++;
                // 递归处理下一个条目
                processNextItem(items.slice(1));
            }
        );

        // 如果Cosmos限流（请求被拒），返回当前已插入的条数
        if (!isRequestAccepted) {
            getContext().getResponse().setBody(insertedCount);
        }
    }

    // 启动批量插入流程
    processNextItem(stockCountItems);
}

这里核心就是用getContext().getResponse().setBody(...)明确返回一个整数，不管是成功的条数还是错误标识，绝对不能让它默认返回null。

2. 检查调用端的.NET代码匹配度 #

既然错误里提到了System.Int32，说明你是用.NET SDK调用的存储过程，要确保调用代码指定的返回类型和存储过程返回的整数完全匹配：

// 注意：分区键必须和你文档的分区键一致，这里假设tenantId是分区键
var partitionKey = new PartitionKey(tenantId);
var spResponse = await container.Scripts.ExecuteStoredProcedureAsync<int>(
    "spBulkAddStockCountItems",
    partitionKey,
    tenantId,
    stockCountId,
    stockCountItems
);

int successCount = spResponse.Resource;
// 可以根据返回值判断结果：比如-1代表出错，大于等于0代表成功条数
if (successCount == -1)
{
    // 处理插入错误逻辑
}

另外要注意分区键的正确性——存储过程操作必须指定正确的分区键，否则不仅可能引发权限或路由错误，也可能间接导致返回值异常。

3. 额外排查点 #

• 如果你的stockCountItems里有字段是null，但对应Cosmos文档的属性被定义为必填的int类型，插入时也会出错，但这个错误提示是返回值的问题，所以先优先搞定返回值的问题。
• 测试时可以先给stockCountItems传1-2条数据，快速验证存储过程的返回值是否正确，再逐步放大批量的数量。

这样调整后，调用端就能接收到明确的整数返回值，那个反序列化的错误应该就消失了。

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