优化MS GraphAPI调用：日历事件同步批量请求与代码优化

一、最优调用策略（针对0-1000条事件） #

1. 获取事件总数 #

直接使用$count参数一次性获取总数，无需遍历所有事件：

• 请求头需添加ConsistencyLevel: eventual
• 请求端点：/me/events?$count=true

2. 同步所有事件 #

使用分页查询减少请求次数：

• 设置$top=999（Graph API允许的单页最大数量），1000条数据最多只需2次请求
• 利用@odata.nextLink自动处理分页逻辑

3. 批量操作场景（如批量更新/删除） #

如果同步过程中需要批量修改事件，再使用Graph API的批量请求，注意：

• 单批请求最多包含20个独立请求
• 超过20个时需自动拆分多批处理

二、优化后的代码实现 #

1. 获取个人日历事件总数 #

public async Task<int> GetCalendarEventCountAsync()
{
    try
    {
        return await _graphServiceClient.Me.Events
            .Request()
            .Header("ConsistencyLevel", "eventual")
            .Select("id") // 仅返回id字段减少数据传输量
            .GetCountAsync();
    }
    catch (ServiceException ex)
    {
        // 按需添加日志或自定义异常处理
        throw new InvalidOperationException("获取事件总数失败", ex);
    }
}

2. 分页获取所有日历事件 #

public async Task<List<Event>> GetAllCalendarEventsAsync()
{
    var allEvents = new List<Event>();
    var pageIterator = PageIterator<Event>.CreatePageIterator(
        _graphServiceClient,
        _graphServiceClient.Me.Events.Request().Top(999),
        evt =>
        {
            allEvents.Add(evt);
            return true;
        },
        req => req // 可在此添加额外筛选条件，如$filter
    );

    await pageIterator.IterateAsync();
    return allEvents;
}

3. 优化后的批量请求方法 #

修复原代码的响应ID匹配问题，添加分批处理和错误处理：

public async Task<IEnumerable<T>> ExecuteBatchRequestAsync<T>(IEnumerable<string> requestUrls)
{
    var results = new List<T>();
    const int batchSize = 20; // Graph API单批最大请求数限制
    var urlBatches = requestUrls.Chunk(batchSize); // .NET 6+原生支持拆分，低版本需手动实现分批逻辑

    foreach (var urlBatch in urlBatches)
    {
        var batchContent = new BatchRequestContent();
        var requestIdMap = new Dictionary<string, string>(); // 记录请求ID与对应URL的映射

        // 构建批量请求步骤
        for (int i = 0; i < urlBatch.Length; i++)
        {
            var requestId = (i + 1).ToString();
            var httpRequest = new HttpRequestMessage(HttpMethod.Get, urlBatch[i]);
            batchContent.AddBatchRequestStep(httpRequest, requestId);
            requestIdMap[requestId] = urlBatch[i];
        }

        // 发送批量请求
        var batchResponse = await _graphServiceClient.Batch.Request().PostAsync(batchContent);

        // 逐个处理响应
        foreach (var requestId in requestIdMap.Keys)
        {
            try
            {
                var response = await batchResponse.GetResponseByIdAsync<T>(requestId);
                if (response.IsSuccessStatusCode)
                {
                    results.Add(response.Result);
                }
                else
                {
                    var errorContent = await response.Content.ReadAsStringAsync();
                    throw new InvalidOperationException($"请求 {requestIdMap[requestId]} 失败: {errorContent}");
                }
            }
            catch (Exception ex)
            {
                throw new InvalidOperationException($"处理请求 {requestIdMap[requestId]} 时出错", ex);
            }
        }
    }

    return results;
}

三、原代码的问题说明 #

1. 响应ID匹配错误：第二个循环中requestIndex持续递增，导致无法匹配之前设置的请求ID，无法正确获取响应
2. 未处理分批限制：超过20个请求时会被Graph API直接拒绝
3. 缺失错误处理：未处理请求失败、响应异常等场景
4. 冗余异步调用：requestFunc.Invoke()若仅返回URL，无需异步调用，直接传入URL集合更高效

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