Invoke-Command调用ADF状态的PowerShell脚本随机挂起问题咨询

直接执行Get-AzDataFactoryV2PipelineRun而不通过Invoke-Command调用，很大概率能解决随机挂起的问题。

原因分析 #

Invoke-Command即使是本地调用，也会创建独立的PowerShell运行空间（Runspace），这种额外的会话层会引入线程调度、上下文传递的复杂度，和ActiveBatch的调度环境交互时容易出现线程阻塞、资源未释放的情况，导致脚本看似挂起。而直接执行命令是在当前PowerShell会话内运行，避免了跨运行空间的开销，也消除了潜在的线程等待冲突点。

现有脚本的额外优化点 #

除了去掉Invoke-Command，原脚本还有几个可以避免问题、提升稳定性的调整：

• 避免重复登录Azure：原脚本每次循环都执行Connect-AzAccount，但-Scope Process已经让登录上下文在整个进程生命周期内有效，把登录逻辑移到循环外即可，减少不必要的认证开销。
• 修复变量引用错误：原Switch块里的$Status变量未定义，应该用$Result.Status替代，否则输出会是空值。
• 优化输出适配ActiveBatch：ActiveBatch对Write-Host的捕获可能不稳定，改用Write-Output能更可靠地将日志输出到调度工具控制台。

修改后的完整脚本 #

[Int32] $PollSeconds = 30
$PipelineRunId = "111111111111111111"

function Invoke-RetryCommand {
    Param(
        [Parameter(Mandatory = $True)] [scriptblock] $ScriptBlock,
        [Int32] $Maximum = 3,
        [Int32] $Delay = 10
    )
    $Attempt = 0

    While ($True) {
        $Attempt++

        Try {
            # 直接执行脚本块，移除Invoke-Command
            return & $ScriptBlock               
        }
        Catch {
            If ($Attempt -eq $Maximum) {
                Throw
            }
            Write-Error $error[0] -ErrorAction Continue
            Start-Sleep -Seconds ($Delay * $Attempt)
        }
    }
}

# 仅登录一次，放在循环外部
Connect-AzAccount -Credential $Credential -Tenant $TenantId -Subscription $SubscriptionId -ServicePrincipal -Scope Process
$ProcessContext = Get-AzContext

$IsRunning = $True

While ($IsRunning) {
    # 获取ADF管道运行状态
    $Result = Invoke-RetryCommand -ScriptBlock {
        Get-AzDataFactoryV2PipelineRun -ResourceGroupName $ResourceGroupName -DataFactoryName $DataFactoryName -PipelineRunId $PipelineRunId -DefaultProfile $ProcessContext -ErrorAction Stop
    }
    
    # 根据状态执行对应逻辑
    Switch ($Result.Status) {
        "Queued" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            Start-Sleep -Seconds $PollSeconds
        }
        "InProgress" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            Start-Sleep -Seconds $PollSeconds
        }
        "Canceling" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            Start-Sleep -Seconds $PollSeconds
        }
        "Failed" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            $FailureMessage = $Result.Message.ToString()
            $ErrorMessage = @"

############ADF FAILURE############ 
ADF Pipeline Name = $PipelineName 
GUID = $PipelineRunId 
ADF Failure Message: $FailureMessage 
################################## 

"@
            Throw $ErrorMessage
        }
        "Cancelled" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            Throw "CANCELLED - ADF Pipeline Name = $PipelineName, GUID = $PipelineRunId"
        }
        "Succeeded" {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
            Write-Output "SUCCEEDED - ADF Pipeline Name = $PipelineName, GUID = $PipelineRunId"
            $Result | Format-List | Out-String | Write-Output
            $IsRunning = $False
            Break
        }
        Default {
            Write-Output "$(Get-Date -format 'HH:mm:ss') : $($Result.Status)"
        }
    }
}

内容的提问来源于stack exchange，提问作者Ajan Balakumaran