我正在构建一个ADF V2解决方案,需要将CSV文件中的数据导入Azure SQL数据仓库 . 每次将新的CSV文件添加到blob容器时,我都想使用新的Azure Blob存储触发器(事件触发器)来执行管道 . CSV文件按以下层次结构组织(容器和虚拟文件夹):
-
FactoryId(1,2,3,..)
-
- 年(2017年,2018年......)
-
----月(01,02,...)
-
------- Day(01,02,... 30)
我想从已引发事件触发器的blob的FilePath设置名称为FactoryId的ADF变量(例如/ 1/2018/06/25 - FactoryId将为1) . 然后,我想将此值用作Azure SQL DWH中表的列的输入值 . 该表将具有与CSV文件相同的列加上这一个FactoryId,我想从变量/ filepath值填充此值 .
这可能与ADF V2有关,如果没有,那么你的其他建议是什么 .
谢谢
1 回答
当blob事件触发器触发时,它会为管道提供两个变量:folderPath和fileName . 要访问这些变量,请使用@triggerBody() . fileName或@triggerBody() . folderPath表达式 .
请参考this link .
目前,没有简单的方法可以直接实现这一点 . 你可以使用custom activity .