0

我是使用 azure 数据工厂的新手，我正在尝试设置一个管道，从 API 获取特定时间范围内的数据。到目前为止，我一直在做的事情是：我为 API 调用创建了一个翻转窗口管道，以将数据作为 JSON 文件引入并存储在具有特定时间戳的 ADL 文件夹中。问题是我只想要当前日期和时间的数据并存储在该特定文件夹中，例如年/月/日/小时/ json 文件我如何告诉 URL 只是在触发器被激活的小时内获取数据（触发器是设置为每个整小时，需要从例如凌晨 3 点到 3:59 获取数据。我能够从特定时间戳获取数据，但不能从当前时间获取数据，这将与触发时间相关联。URL 代码：?sourceId=1LuOA,9VKZ2,CISG1 ,D7UIQ,gu4me,hSZGT,K582n,MnkPP,Mxgt4,N4hAZ,PvECt,Qhr1i,uIWnW,vot1K,XAbJ4,XRH1E,ZbKW0,Zjrs3,ZttLo&

水槽代码：

beacon/@{formatDateTime(adddays(utcnow(),0),'yyyy')}/@{formatDateTime(adddays(utcnow(),0),'MM')}/@{formatDateTime(adddays(utcnow(),0),'dd')}

当我尝试添加小时数时，我得到一个不代表小时数的奇怪文件夹。

4

1 回答 1

0

在您的管道中，定义一个管道参数，例如 windowStart。然后将 trigger().outputs.windowStartTime 传递给您的管道参数。然后，如果您预期的文件夹名称是 abc/year/month/day/hour。你可以使用abc/@{formatDateTime(pipeline().parameters.windowStart,'yyyy')/@{formatDateTime(pipeline().parameters.windowStart,'MM')/@{formatDateTime(pipeline().parameters.windowStart, 'dd')/@{formatDateTime(pipeline().parameters.windowStart,'HH')}

请参考此用于翻滚窗口。 https://docs.microsoft.com/en-us/azure/data-factory/how-to-create-tumbling-window-trigger#tumbling-window-trigger-type-properties

于 2018-05-28T12:34:37.003 回答