根据列的存在拆分数据因子管道
Splitting a Data Factor Pipeline based on the presence of a column
我正在创建一个管道以将一系列 csvs 提取到 Azure SQL 数据库
CSV 来自一个名为 SystmOne 的医疗软件,CSV 是 完整 数据集或 delta 数据集。它们的模式的唯一区别是存在一个附加列:RemovedData
.
此列的存在将需要管道中的额外步骤(使用 RemovedData == true
从数据库中删除任何行)。
在 ADF 或(带有数据流预览的 ADF)中是否可以查询文件中是否存在列并根据结果拆分管道?
我无法控制文件的初始输出。
您可以使用 getMetadataActivty columnCount 属性 检查源数据集中的列数,然后使用 If Activity 执行您想要的操作。
IF activity 中的表达式:@equals(activity('YourGet Metadata').output.columnCount,numberOfColumns)
然后根据正确或错误选择具有适当架构的数据集。
我正在创建一个管道以将一系列 csvs 提取到 Azure SQL 数据库
CSV 来自一个名为 SystmOne 的医疗软件,CSV 是 完整 数据集或 delta 数据集。它们的模式的唯一区别是存在一个附加列:RemovedData
.
此列的存在将需要管道中的额外步骤(使用 RemovedData == true
从数据库中删除任何行)。
在 ADF 或(带有数据流预览的 ADF)中是否可以查询文件中是否存在列并根据结果拆分管道?
我无法控制文件的初始输出。
您可以使用 getMetadataActivty columnCount 属性 检查源数据集中的列数,然后使用 If Activity 执行您想要的操作。
IF activity 中的表达式:@equals(activity('YourGet Metadata').output.columnCount,numberOfColumns)
然后根据正确或错误选择具有适当架构的数据集。