Azure 数据工厂：从 csv 读取并逐行复制到 cosmos db

Question

我是 Azure 数据工厂的新手。我正在尝试解决以下问题：

1. 从 Azure Blob 读取 csv 文件
2. 逐行解析它并将每一行转储到现有的 cosmos 数据库中

我目前正在研究一种解决方案：

1. 将数据从源 (csv) 复制到接收器（Azure 存储 Table）
2. ForEach activity 解析 table 并将行复制到 db

这是正确的方法吗？如果是，我应该如何设置 ForEach 的动态内容activity？

---

注：

我试过这个解决方案 (link) 但我收到一条错误消息说

Reading or replacing offers is not supported for serverless accounts

这意味着

CosmosDB Serverless is not currently supported as Sink for the Data flow in Azure Data Factory.

Answer 1

如果使用 Lookup + ForEach actives，则 Foreach Items 应该是：

@activity('Lookup1').output.value

您的解决方案可能很难实现。

既然你发现 Data Flow 不支持 Cosmos DB Serverless，我想你可以参考这个教程：Copy Data From Blob Storage To Cosmos DB Using Azure Data Factory

它使用复制活动将数据从 Blob 存储中的 csv 文件直接复制到 Azure Cosmos DB。