如何通过Azure Data Factory数据流实现CRM实体记录的单事务创建？

首先明确：Azure Data Factory 数据流（DataFlow）本身不支持跨多个CRM接收器的事务回滚，因为数据流基于Spark分布式架构，每个接收器是独立的写入操作，无法纳入同一事务上下文。以下是几种可行的替代方案：

方案1：使用Azure Logic Apps/Power Automate 处理事务性批量操作 #

直接借助Power Platform原生的事务支持来实现：

• 读取输入的多层JSON文件，解析出各实体的记录数据
• 使用Dataverse连接器的执行批量操作（Execute a batch operation）动作，开启事务（设置IsolationLevel为ReadCommitted或Serializable）
• 在批量请求中依次添加多个实体的创建请求
• 批量操作会自动处理事务：只要其中一个创建请求失败，所有已执行的操作都会被回滚

方案2：通过Azure Function 封装事务逻辑 #

将多实体创建的事务逻辑封装到Azure Function中，在ADF中调用该Function：

• 编写Function（推荐C#，使用Microsoft.PowerPlatform.Dataverse.Client SDK）：
  1. 接收传入的JSON数据，解析各实体记录
  2. 初始化Dataverse ServiceClient，调用StartTransaction()开启事务
  3. 依次调用Create()方法创建每个实体记录
  4. 若任何一步抛出异常，调用RollbackTransaction()回滚；否则调用CommitTransaction()提交
• 在ADF中：
  • 若用数据流，可使用Azure Function接收器将JSON数据传递给Function
  • 若用管道，可使用Azure Function活动调用并传入参数

方案3：ADF管道补偿机制（补偿式回滚） #

如果必须在ADF管道内实现，可通过补偿活动模拟事务效果：

• 管道步骤：
  1. 使用Web活动调用CRM API创建第一个实体，将返回的记录ID存入管道变量
  2. 调用第二个实体的创建Web活动
  3. 若第二个活动失败，触发补偿活动：调用CRM API根据之前保存的ID删除第一个实体记录
  4. 重复上述逻辑处理第三个实体
• 注意：这种方式是事后补偿，并非严格意义上的数据库事务，若在删除第一个实体时出现额外错误，可能导致数据不一致，仅适合对一致性要求相对较低的场景

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