Azure C# Function如何将完整请求内容写入Cosmos DB输出文档

问题根因 #

Azure Function Cosmos DB 输出绑定的 IAsyncCollector<T>.AddAsync 方法不直接支持 Stream 类型参数，传入固定字符串可正常写入是因为字符串会被内置序列化器自动封装为符合要求的文档对象，Stream 类型的字节流无法被序列化器直接识别处理。

方案1：直接读取Stream为字符串后写入（适合保留完整原始JSON） #

该方案无需提前定义SendGrid payload模型，可完整保留原始推送结构，同时灵活补充自定义字段满足指定结构要求：

// 重置Stream读取位置，避免之前读过导致读取结果为空
sgBody.Position = 0;
// 读取Stream为原始JSON字符串
using var reader = new StreamReader(sgBody, Encoding.UTF8);
string rawSendGridJson = await reader.ReadToEndAsync();

// 按你需要的结构构造Cosmos DB文档
var cosmosDocument = new
{
    id = Guid.NewGuid().ToString(), // Cosmos DB必填的唯一ID，可替换为SendGrid推送的业务唯一ID避免重复写入
    receiveTime = DateTime.UtcNow,
    source = "SendGridWebhook",
    // 反序列化为JsonElement后写入，可在Cosmos DB中存储为原生JSON结构，而非转义字符串
    sendGridRawPayload = JsonSerializer.Deserialize<JsonElement>(rawSendGridJson)
    // 其他自定义字段可在此补充
};

// 写入Cosmos DB
await documentsOut.AddAsync(cosmosDocument);

方案2：反序列化后校验再写入（适合需要对推送内容做规则校验的场景） #

如果需要先校验SendGrid推送内容的合法性，再按指定结构写入，可以用强类型模型处理：

// 定义SendGrid Webhook事件模型，也可直接使用SendGrid官方SDK提供的现成模型
public class SendGridEvent
{
    public string Email { get; set; }
    public string Event { get; set; }
    public string SgMessageId { get; set; }
    // 其他需要用到的字段按需补充
}

// 直接从Stream反序列化
sgBody.Position = 0;
var sendGridEvents = await JsonSerializer.DeserializeAsync<List<SendGridEvent>>(sgBody);

// 此处添加你的校验逻辑
if (sendGridEvents == null || !sendGridEvents.Any())
{
    return new BadRequestResult();
}

// 按指定结构构造文档
var cosmosDocument = new
{
    id = sendGridEvents.First().SgMessageId,
    events = sendGridEvents,
    processStatus = "Success",
    processTime = DateTime.UtcNow
};

await documentsOut.AddAsync(cosmosDocument);

注意事项 #

• 读取Stream前必须设置 Position = 0，否则如果函数触发绑定已经读过一次Stream，会读取到空内容
• 不要直接将原始JSON字符串作为字段值写入，否则会被存储为带转义符的字符串，不利于后续Cosmos DB查询
• 若没有手动指定文档的id字段，Cosmos DB SDK会自动生成该字段，推荐用业务唯一ID手动赋值避免重复写入

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