Ayuda de subprocesamiento múltiple con Powershell

Question

Tengo una secuencia de comandos que ejecutará y hará ping a todos los servidores de una lista que está almacenada en SQL Server. El script funciona bien pero lo hace todo secuencialmente (cojo).

¿Alguien puede ayudarme a cómo cambiaría esto para usar multiprocesamiento en lugar de un ciclo foreach?

$Server = "ServerName" 
$Database = "DatabaseName" 

$con = "server=$Server;database=$Database;Integrated Security=sspi" 
$cmd = "SELECT ServerName FROM dbo.vwServerListActive" 

    $da = new-object System.Data.SqlClient.SqlDataAdapter ($cmd, $con) 

    $dt = new-object System.Data.DataTable 

    $da.fill($dt) | out-null 


    foreach ($srv in $dt) 
    { 

    $ping = new-object System.Net.NetworkInformation.Ping 
    $Reply = $ping.send($srv.ServerName) 

    $ServerName = $srv.ServerName 

    $ServerName 
    $Reply.status 

    if ($Reply.status –eq “Success”) 
    { 
     $sql = "UPDATE dbo.ServerList SET GoodPing = 1 WHERE GoodPing <> 1 AND ServerName = '$ServerName'" 

    } 
    else 
    { 
     $sql = "UPDATE dbo.ServerList SET GoodPing = 0 WHERE GoodPing <> 0 AND ServerName = '$ServerName'" 
    } 

    $Reply = "" 

    invoke-sqlcmd -serverinstance $Server -database $Database -query $sql 


    } 

Answer 1

Si tiene PowerShell 2.0, puede hacer uso de trabajos en segundo plano. Tendrá que dividir su lista de servidores en "grupos".Dada una tabla de origen con serverName y nombre_de_grupo:

CREATE TABLE [dbo].[vwServerListActive](
    [serverName] [varchar](50) NULL, 
    [groupName] [char](1) NULL 
) 

Una ligera modificación de la secuencia de comandos (guardar como forum.ps1):

param($groupName) 

$Server = "$env:computername\sql2k8" 
$Database = "dbautility" 

$con = "server=$Server;database=$Database;Integrated Security=sspi" 
$cmd = "SELECT ServerName FROM dbo.vwServerListActive WHERE groupName ='$groupName'" 

    $da = new-object System.Data.SqlClient.SqlDataAdapter ($cmd, $con) 

    $dt = new-object System.Data.DataTable 

    $da.fill($dt) | out-null 


    foreach ($srv in $dt) 
    { 

    $ping = new-object System.Net.NetworkInformation.Ping 
    $Reply = $ping.send($srv.ServerName) 

    new-object PSObject -Property @{ServerName=$($srv.ServerName); Reply=$($Reply.status)} 

    } 

A continuación, puede llamar a la secuencia de comandos para los diferentes grupos:

#groupName A 
start-job -FilePath .\forum.ps1 -Name "Test" -ArgumentList "A" 
#groupName B 
start-job -FilePath .\forum.ps1 -Name "Test" -ArgumentList "B" 

Get-Job -name "test" | wait-job | out-null 
Get-Job -name "test" | receive-job 

#get-job -name "test" |remove-job 

Si está utilizando PowerShell V1 o sqlps, puede usar System.Diagnostics.ProcessStartInfo para iniciar procesos independientes de powershell.exe y pasar el nombre del grupo.

param($groupName) 

    $StartInfo = new-object System.Diagnostics.ProcessStartInfo 
    $StartInfo.FileName = "$pshome\powershell.exe" 
    $StartInfo.Arguments = " -NoProfile -Command C:\scripts\forum.ps1 $groupName" 
    $StartInfo.WorkingDirectory = "C:\scripts" 
    $StartInfo.LoadUserProfile = $true 
    $StartInfo.UseShellExecute = $true 
    [System.Diagnostics.Process]::Start($StartInfo) > $null 

Answer 2

Aquí hay una scripts page que podría ser útil para usted. Todavía no lo he usado, así que no puedo comentar más allá de eso.

Answer 3

Powershell realmente no hace multihebra en absoluto. Me las arreglé para colocarlo en su lugar fingiéndolo con una secuencia de comandos de "fuego y olvido" iniciada con "start [powershell path] scriptname.ps1". Descarguará múltiples secretos, pero no podrá obtener datos de ellos sin realizar una ejecución final a través de una base de datos u otro mecanismo de transmisión de mensajes. El seguimiento cuando los procesos secundarios finalizan es complicado también.

cmd /c "start /min /low C:\Windows\System32\WindowsPowerShell\v1.0\powershell.exe -command .\evtlogparse.ps1 " 

En su caso lo que está configurando una cadena SQL como parte del bucle foreach, se puede tratar de poner el código de actualización de base de datos en una segunda secuencia de comandos que el fuego apagado. Posiblemente tendrá muchos procesos diferentes intentando actualizar la misma tabla de base de datos, por lo que la posibilidad de problemas de temporización es bastante grande.

Además, dado que estás lanzando umpty nuevas instancias de PowerShell, vas a comer mucha memoria para que funcione. El ciclo foreach puede ser más rápido que iniciar un montón de procesos.

Por lo tanto, se puede hacer, pero no es nada parecido a lo bonito.

Answer 4

Primero, sugiero crear solo una vez que la variable $ ping fuera de 'foreach ..'.
Quizás una solución más simple ... ahora que está usando SQL 2008, ¿por qué no usar el método SMO 'enumAvailableSqlServers: "... SMOApplication] :: EnumAvailableSqlServers ($ false)". Esto le dará una lista de todos los servidores disponibles en la red. Aquí está el enlace de Microsoft MSDN para que pueda leer al respecto: http://msdn.microsoft.com/en-us/library/ms210350.aspx

Answer 5

(Editado según la sugerencia + Throttling Requisito de Chad Miller + Wait-Job fix + fix STA)

Support.ps1

powershell -File "Main.ps1" -Sta 

Main.ps1

$Server = "ServerName" 
$Database = "DatabaseName" 

$con = "server=$Server;database=$Database;Integrated Security=sspi" 
$cmd = "SELECT ServerName FROM dbo.vwServerListActive" 

$da = New-Object System.Data.SqlClient.SqlDataAdapter -ArgumentList $cmd, $con 

$dt = New-Object System.Data.DataTable 

$da.Fill($dt) | Out-Null 

$ThrottleLimit = 10 
$activeJobs = New-Object 'System.Collections.Generic.List[Int32]' 

$JobStateChanged = { 
    param ( 
     [System.Object]$Sender, 
     [System.Management.Automation.JobStateEventArgs]$EventArgs 
    ) 

    switch ($EventArgs.JobStateInfo.State) 
    { 
     Blocked { return } 
     Completed { $activeJobs.Remove($Sender.Id); break } 
     Failed { $activeJobs.Remove($Sender.Id); break } 
     NotStarted { return } 
     Running { return } 
     Stopped { $activeJobs.Remove($Sender.Id); break } 
    } 

    Unregister-Event -SourceIdentifier ("{0}.StateChanged" -f $Sender.Name) 
} 

foreach ($srv in $dt) 
{ 
    while ($true) 
    { 
     if ($activeJobs.Count -lt $ThrottleLimit) 
     { 
      $job = Start-Job -InitializationScript { 
       Add-PSSnapin -Name SqlServerCmdletSnapin100 
      } -ScriptBlock { 
       param ( 
        [String]$Server, 
        [String]$Database, 
        [String]$ServerName 
       ) 

       if (Test-Connection -ComputerName $ServerName -Quiet) 
       { 
        $sql = "UPDATE dbo.ServerList SET GoodPing = 1 WHERE GoodPing <> 1 AND ServerName = '$ServerName'" 
       } 
       else 
       { 
        $sql = "UPDATE dbo.ServerList SET GoodPing = 0 WHERE GoodPing <> 0 AND ServerName = '$ServerName'" 
       } 

       Invoke-SqlCmd -ServerInstance $Server -Database $Database -Query $sql 
      } -ArgumentList $Server, $Database, $srv.ServerName 

      $activeJobs.Add($job.Id) 

      Register-ObjectEvent -InputObject $job -EventName StateChanged -SourceIdentifier ("{0}.StateChanged" -f $job.Name) -Action $JobStateChanged 

      break 
     } 
    } 
} 

Get-Job | Where-Object { $_.State -eq "Running" } | Wait-Job 
Get-Job | Remove-Job 

Answer 6

tan cerca .... esto es lo que tengo

add-pssnapin SqlServerCmdletSnapin100 

$Server = "ServerName" 
$Database = "DatabaseName" 

$con = "server=$Server;database=$Database;Integrated Security=sspi" 
$cmd = "SELECT ServerName FROM dbo.vwServerListActive" 

$da = New-Object System.Data.SqlClient.SqlDataAdapter -ArgumentList $cmd, $con 

$dt = New-Object System.Data.DataTable 

$da.Fill($dt) | Out-Null 


foreach ($srv in $dt) 
{  
    Start-Job -ScriptBlock { 
     param ( 
      [String]$Server, 
      [String]$Database, 
      [String]$ServerName 
     ) 


    if (Test-Connection -ComputerName $ServerName -quiet) 
      { 
       $sql = "UPDATE dbo.ServerList SET GoodPing = 1 WHERE GoodPing <> 1 AND ServerName = '$ServerName'" 
      } 
      else 
      { 
       $sql = "UPDATE dbo.ServerList SET GoodPing = 0 WHERE GoodPing <> 0 AND ServerName = '$ServerName'" 
      } 

      Invoke-SqlCmd -ServerInstance $Server -Database $Database -Query $sql 
    } -ArgumentList $Server, $Database, $srv.ServerName 
} 

y parece estar empezando múltiples puestos de trabajo ... pero mi mesa nunca se actualiza. Si elimino el material "Start-Job" y la lista argumentativa y uso $ srv.ServerName, entonces funciona de forma secuencial como lo hacía antes. ¿Algunas ideas? (Muchas gracias por cierto para todas las respuestas)

Answer 7

Aquí hay un guión de Jim Truher para trabajos en segundo plano en PowerShell v1.0:

http://jtruher.spaces.live.com/blog/cns!7143DA6E51A2628D!130.entry

PowerShell v2.0 tiene trabajos en segundo plano incorporado:

http://technet.microsoft.com/en-us/library/dd347692.aspx

-Oisin