Azure 数据工厂 - >查找、ForEach 和复制活动



我想从azure突触中获取一个文件,并使用ADf将其加载到ADL中。我想阅读过去13个月的数据,并为每个月制作一个不同的文件。我制作了一个CSV文件,在其中我写下了每个月的开始日期和结束日期,并对该文件进行了查找活动。然后使用foreach活动,从复制活动加载文件。现在我想为每个月的数据编写一个查询。

从edw.actbaldly中选择*,其中INSERT_DATE>activity('Lookup1'(.output.value.startdate和INSERT_DATE<activity('Lookup1'(.output.value.EndDate

从edw.actbaldly中选择*,其中INSERT_DATE>item((.startdate和INSERT_DATE<item((。结束日期

我使用这些来查询,但无法读取查找活动的数据并获取数据。请帮我查询一下。提前谢谢。

我假设Lookup1 CSV列标题是startdateenddate

在您的ForEach>设置>您将拥有@activity('Lookup1').output.value的项目

在ForEach块中,您的Copy活动Source查询将显示为:

select * from edw.factbaldly where INSERT_DATE > '@{item().startdate}' and INSERT_DATE < '@{item().enddate}'

ADF将用字符串替换@{thing},这样您就可以在查询中获得带引号的字符串形式的日期

也许你也想要其中一个符号>=或者<=?

事实上,您可能不需要维护CSV,因为您可以使用变量和ADF函数utcnow((、addToTime((和startOfMonth((来查找日期

在查找活动中,您将获取@item((.startdate和@item。结束日期。或者我猜你已经在ForEach之前的查找中设置了这些。但是,要在生成新文件时使用此详细信息,必须使用"复制活动"源部分中问题的查询。

如果不能直接在文件上使用查询,可以将整个文件导入DB表,然后在复制活动源中使用查询。

您可以使用类似的表达式

@concat('select * from edw.factbaldly where INSERT_DATE> >',item().startdate,'and INSERT_DATE <',item().EndDate)

如果我把你放在哪里,我本可以添加一个集合变量活动并测试上面的表达式。set变量应该为我们提供一个语法正确的TSQL语句。HTH-

相关内容

  • 没有找到相关文章

最新更新