ADF滚动窗口触发器更新startTime属性的行为可以通过以下步骤来实现:
创建ADF滚动窗口触发器。在ADF管道中的触发器部分,添加一个滚动窗口触发器。设置触发器的时间间隔和滚动窗口大小。
在ADF管道中添加一个活动(例如:Copy活动)。将该活动放在滚动窗口触发器之后。
在活动的属性中,添加一个参数(例如:startTime)。将该参数与滚动窗口触发器的startTime属性进行绑定。
在活动的参数设置中,使用表达式来更新startTime属性的值。代码示例如下:
"parameters": {
"startTime": {
"type": "string",
"defaultValue": "@trigger().outputs.windowStartTime"
}
},
"activities": [
{
"name": "CopyData",
"type": "Copy",
"inputs": [
{
"referenceName": "SourceDataset",
"type": "DatasetReference"
}
],
"outputs": [
{
"referenceName": "DestinationDataset",
"type": "DatasetReference"
}
],
"typeProperties": {
"source": {
"type": "BlobSource"
},
"sink": {
"type": "BlobSink"
}
},
"scheduler": {
"frequency": "Day",
"interval": 1
},
"policy": {
"timeout": "7.00:00:00",
"retry": 0,
"retryIntervalInSeconds": 30,
"secureOutput": false
},
"parameters": {
"startTime": {
"value": "@trigger().outputs.windowStartTime"
}
}
}
]
在上述代码示例中,使用了@trigger().outputs.windowStartTime
来获取滚动窗口触发器的startTime属性的值,并将其赋值给活动的参数startTime。
这样,每次触发滚动窗口触发器时,活动的参数startTime都会更新为滚动窗口触发器的startTime属性的值。