通过

在 Azure 数据工厂和 Synapse Analytics 中执行 wait 活动

  • 项目

在管道中使用等待活动时，管道将等待一段指定的时间，然后继续执行后续活动。

适用于： Azure 数据工厂 Azure Synapse Analytics

提示

试用 Microsoft Fabric 中的数据工厂，这是一种适用于企业的一站式分析解决方案。 Microsoft Fabric 涵盖从数据移动到数据科学、实时分析、商业智能和报告的所有内容。 了解如何免费开始新的试用！

使用 UI 创建 Wait 活动

若要在管道中使用 Wait 活动，请完成以下步骤：

  1. 在管道“活动”窗格中搜索“Wait”，然后将 Wait 活动拖动到管道画布上。

  2. 如果尚未选择画布上的新 Wait 活动，请选择它及其“设置”选项卡，以编辑其详细信息。

    显示“Wait”活动的 UI。

  3. 输入活动等待的秒数。 这可以是文本数字，也可以是动态表达式、函数、系统变量或其他活动的输出的任意组合。

语法

{
    "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"
            }
        ]
    }
}

相关内容

参阅支持的其他控制流活动：