如何让Azure Stream Analytics等待Function App源代码控制部署完成？

这个问题的核心原因很清晰：当你在同一个ARM模板里部署App Service Plan、Function App和Stream Analytics作业时，ARM只会确保Function App资源本身创建完成，不会等待源代码控制触发的异步代码部署流程结束。所以Stream Analytics在绑定aggregate函数时，代码还没部署到位，就会抛出NotFound错误。

下面给你几个可行的解决办法，按推荐程度排序：

1. 使用ARM部署脚本轮询函数就绪状态 #

这是最直接的内置解决方案，通过添加一个PowerShell部署脚本资源，在Stream Analytics创建输出前，反复检查aggregate函数是否存在，直到就绪再继续后续部署。

示例ARM模板片段 #

首先添加部署脚本资源：

{
  "type": "Microsoft.Resources/deploymentScripts",
  "apiVersion": "2020-10-01",
  "name": "WaitForAggregateFunction",
  "location": "[resourceGroup().location]",
  "dependsOn": [
    // 依赖Function App资源的创建完成
    "[resourceId('Microsoft.Web/sites', 'function-app-xyvfjtuivnvow')]"
  ],
  "kind": "AzurePowerShell",
  "properties": {
    "forceUpdateTag": "[utcNow()]",
    "azPowerShellVersion": "7.2",
    "scriptContent": "
      $functionAppName = 'function-app-xyvfjtuivnvow'
      $functionName = 'aggregate'
      $maxRetryAttempts = 30
      $retryIntervalSeconds = 10
      $currentAttempt = 0

      Write-Host 'Starting to wait for function $functionName to be deployed...'

      do {
        $currentAttempt++
        try {
          $function = Get-AzFunctionAppFunction -Name $functionAppName `
            -ResourceGroupName $env:RESOURCE_GROUP_NAME `
            -FunctionName $functionName `
            -ErrorAction Stop
          
          if ($function) {
            Write-Host 'Success: Function $functionName is now available!'
            break
          }
        }
        catch {
          Write-Host 'Attempt $currentAttempt/$maxRetryAttempts: Function not found yet, retrying in $retryIntervalSeconds seconds...'
        }
        Start-Sleep -Seconds $retryIntervalSeconds
      } while ($currentAttempt -lt $maxRetryAttempts)

      if ($currentAttempt -ge $maxRetryAttempts) {
        throw 'Timeout waiting for function $functionName to deploy'
      }
    ",
    "timeout": "PT10M", // 根据你的部署时长调整超时时间
    "cleanupPreference": "OnSuccess",
    "retentionInterval": "P1D"
  }
}

然后修改Stream Analytics作业的输出资源，让它依赖这个部署脚本：

{
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "apiVersion": "2020-03-01",
  "name": "[concat(variables('streamAnalyticsJobName'), '/FunctionAppOutput')]",
  "dependsOn": [
    // 依赖部署脚本完成，确保函数已就绪
    "[resourceId('Microsoft.Resources/deploymentScripts', 'WaitForAggregateFunction')]"
  ],
  "properties": {
    // 你的Function App输出配置...
  }
}

2. 拆分部署阶段（适合CI/CD场景） #

如果用Azure DevOps、GitHub Actions等工具部署，可以把流程拆成两个阶段：

• 第一阶段：部署App Service Plan、Function App以及源代码控制配置，等待代码部署完成（比如Azure DevOps的Azure Function App Deployment任务自带等待部署完成的选项）。
• 第二阶段：部署Stream Analytics作业的输出绑定，此时函数已经部署完毕，不会出现找不到的问题。

3. 利用Function App部署完成的Webhook触发后续部署 #

你可以给Function App的源代码控制配置添加一个Webhook，当代码部署完成后，自动触发Stream Analytics输出部分的部署。不过这种方式需要拆分ARM模板，并且额外配置Webhook，复杂度稍高，适合有特定自动化需求的场景。

注意事项 #

• 调整部署脚本中的maxRetryAttempts和retryIntervalSeconds：如果你的代码部署需要更长时间（比如大型项目），要适当增加重试次数或延长间隔。
• 权限配置：确保部署模板使用的身份（比如服务主体）拥有Microsoft.Web/sites/functions/read的权限，否则脚本无法检查函数状态。

内容的提问来源于stack exchange，提问作者Víctor Vargas