在 Azure 数据工厂和 Synapse Analytics 中执行 wait 活动
在管道中使用等待活动时,管道将等待一段指定的时间,然后继续执行后续活动。
适用于:Azure 数据工厂 Azure Synapse Analytics
使用 UI 创建 Wait 活动
若要在管道中使用 Wait 活动,请完成以下步骤:
在管道“活动”窗格中搜索“Wait”,然后将 Wait 活动拖动到管道画布上。
如果尚未选择画布上的新 Wait 活动,请选择它及其“设置”选项卡,以编辑其详细信息。
语法
{
"name": "MyWaitActivity",
"type": "Wait",
"typeProperties": {
"waitTimeInSeconds": 1
}
}
Type 属性
属性 | 说明 | 允许的值 | 必需 |
---|---|---|---|
name | Wait 活动的名称。 |
String | 是 |
type | 必须被设置为 Wait。 | String | 是 |
waitTimeInSeconds | 管道在继续进行处理前所等待的秒数。 | Integer | 是 |
示例
注意
本部分提供运行管道的 JSON 定义和示例 PowerShell 命令。 有关使用 Azure PowerShell 和 JSON 定义创建管道的分步说明演练,请参阅教程:使用 Azure PowerShell 创建数据工厂。
等待活动的管道
在此示例中,管道包含两个活动:Until 和 Wait。 等待活动被配置为等待 1 秒。 管道循环运行 Web 活动,在每次运行之间等待 1 秒。
{
"name": "DoUntilPipeline",
"properties": {
"activities": [
{
"type": "Until",
"typeProperties": {
"expression": {
"value": "@equals('Failed', coalesce(body('MyUnauthenticatedActivity')?.status, actions('MyUnauthenticatedActivity')?.status, 'null'))",
"type": "Expression"
},
"timeout": "00:10:00",
"activities": [
{
"name": "MyUnauthenticatedActivity",
"type": "WebActivity",
"typeProperties": {
"method": "get",
"url": "https://www.fake.com/",
"headers": {
"Content-Type": "application/json"
}
},
"dependsOn": [
{
"activity": "MyWaitActivity",
"dependencyConditions": [ "Succeeded" ]
}
]
},
{
"type": "Wait",
"typeProperties": {
"waitTimeInSeconds": 1
},
"name": "MyWaitActivity"
}
]
},
"name": "MyUntilActivity"
}
]
}
}
相关内容
参阅支持的其他控制流活动: