使用Azure Function读取CosmosDB表变更馈送出现编译错误求解决

1. 问题根因 #

你遇到的是Azure Functions CSX脚本的编译错误，所有CS0246报错的核心原因是两类缺失：缺少必要的NuGet包引用、缺少对应命名空间的using声明，另外你还未自定义ToDoItem实体类，同时误用了控制台程序的Change Feed Processor初始化逻辑，Azure Functions自带的Cosmos DB触发器已经原生封装了变更监听能力，无需手动实现处理器初始化。

2. 具体修复步骤 #

• 第一步：添加NuGet包引用
  在你的函数目录下新增function.proj文件，写入以下内容：

<Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    <TargetFramework>net6.0</TargetFramework>
    <AzureFunctionsVersion>v4</AzureFunctionsVersion>
  </PropertyGroup>
  <ItemGroup>
    <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.35.4" />
    <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.CosmosDB" Version="4.3.0" />
    <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.Storage" Version="5.1.3" />
  </ItemGroup>
</Project>

• 第二步：修正function.json配置，同时配置Cosmos DB触发器和Blob输出绑定

{
  "bindings": [
    {
      "type": "cosmosDBTrigger",
      "name": "input",
      "direction": "in",
      "leaseCollectionName": "leases",
      "connectionStringSetting": "CosmosDBConnectionString",
      "databaseName": "ToDoList",
      "collectionName": "Items",
      "createLeaseCollectionIfNotExists": true
    },
    {
      "type": "blob",
      "name": "outputBlob",
      "path": "你的目标容器名/%DateTime:yyyyMMdd%/变更记录.txt",
      "connection": "BlobStorageConnectionString",
      "direction": "out"
    }
  ]
}

• 第三步：重写run.csx代码，删除手动初始化Change Feed Processor的逻辑，直接使用触发器接收数据，同时输出到Blob

#r "Newtonsoft.Json"

using System;
using System.Collections.Generic;
using Microsoft.Azure.Cosmos;
using Microsoft.Extensions.Configuration;
using System.Threading;
using Newtonsoft.Json;

// 自定义ToDoItem实体类，和你的Cosmos DB表结构对应
public class ToDoItem
{
    [JsonProperty("id")]
    public string Id { get; set; }
    [JsonProperty("taskName")]
    public string TaskName { get; set; }
    // 其他字段按你的实际表结构补充
}

public static async Task Run(IReadOnlyList<ToDoItem> input, IAsyncCollector<string> outputBlob, ILogger log)
{
    log.LogInformation($"触发变更，共获取到 {input.Count} 条变更记录");
    foreach (var item in input)
    {
        // 序列化变更记录写入Blob
        string record = JsonConvert.SerializeObject(item, Formatting.Indented);
        await outputBlob.AddAsync($"[{DateTime.UtcNow:yyyy-MM-dd HH:mm:ss}] 变更记录：{record}\r\n");
    }
}

• 第四步：配置应用程序设置
  在Azure Functions的配置页添加两个连接字符串：
  • CosmosDBConnectionString：你的Cosmos DB账号连接字符串
  • BlobStorageConnectionString：你的Blob存储账号连接字符串

3. 验证 #

配置完成后重启函数，触发Cosmos DB表的增改操作，即可在目标Blob路径下看到生成的变更记录文件。

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