RunspacePoolを使って、PowerShellを非同期実行

:	$PSCmds = @(					
2:							
3:	"Get-Service | SELECT *",				
4:							
5:	"Get-Process | SELECT *",				
6:							
7:	"New-Item -Path 'C:\PSTest\Test.txt' -ItemType File"	
8:							
9:	)						
10:							
11:	$res = AsyncPowershell $PSCmds				
12:							
13:	function AsyncPowershell($Cmds)			
14:	{						
15:	    try {						
16:	        $MaxRunspace = $Cmds.Length			
17:	        $RunspacePool = [RunspaceFactory]::CreateRunspacePool(1, $MaxRunspace)       
18:	        $RunspacePool.Open()				
19:		   					
20:	        $aryPowerShell  = New-Object System.Collections.ArrayList
21:	        $aryIAsyncResult  = New-Object System.Collections.ArrayList
22:	        for ( $i = 0; $i -lt $MaxRunspace; $i++ )		
23:	        {						
24:	            $Cmd = $Cmds[$i]				
25:	            $PowerShell = [PowerShell]::Create()		
26:		   $PowerShell.RunspacePool = $RunspacePool	
27:	            $PowerShell.AddScript($Cmd)			
28:	            $PowerShell.AddCommand("Out-String")		
29:	            $IAsyncResult = $PowerShell.BeginInvoke()	
30:	                      				
31:	            $aryPowerShell.Add($PowerShell)		
32:	            $aryIAsyncResult.Add($IAsyncResult)		
33:	        }						
34:							
35:	        while ( $aryPowerShell.Count -gt 0 )		
36:	        {						
37:	            for ( $i = 0; $i -lt $aryPowerShell.Count; $i++ )	
38:	            {					
39:	                $PowerShell = $aryPowerShell[$i]		
40:	                $IAsyncResult = $aryIAsyncResult[$i]   	
41:							
42:	                if($PowerShell -ne $null)		
43:	                {					
44:	                    if($IAsyncResult.IsCompleted)		
45:	                    {				
46:	                        $Result = $PowerShell.EndInvoke($IAsyncResult)
47:	                        Write-host $Result		
48:	                        $PowerShell.Dispose()		
49:	                        $aryPowerShell.RemoveAt($i)	
50:	                        $aryIAsyncResult.RemoveAt($i)	
51:	                        {break outer}			
52:	                    }				
53:	                }          				
54:	            }					
55:	            Start-Sleep -Milliseconds 100		
56:	        }						
57:	    } catch [Exception] {				
58:	        Write-Host $_.Exception.Message;		
59:	    } finally {					
60:	        $RunspacePool.Close()				
61:	    }						
62:	}						 

1:	$PSCmds = @(					
2:							
3:	"Get-Service | SELECT *",				
4:							
5:	"Get-Process | SELECT *",				
6:							
7:	"New-Item -Path 'C:\PSTest\Test.txt' -ItemType File"	
8:							
9:	)						
10:							
11:	$res = AsyncPowershell $PSCmds "Server01" "Administrator" "PASSWORD"
12:							
13:	function AsyncPowershell($Cmds, $Server, $AdminAccount, $AdminPassword)
14:	{						
15:	    try {						
16:	        $MaxRunspace = $Cmds.Length			
17:							
18:	        $SecurePassword = ConvertTo-SecureString $AdminPassword -AsPlainText -Force
19:	        $Cred = New-Object -TypeName System.Management.Automation.PSCredential -ArgumentList $AdminAccount, $SecurePassword;
20:	        $RunspaceConnectionInfo = New-Object System.Management.Automation.Runspaces.WSManConnectionInfo
21:	        $RunspaceConnectionInfo.Credential = $Cred		
22:							
23:	        $RunspaceConnectionInfo.ComputerName = $Server	
24:	        $RunspacePool = [RunspaceFactory]::CreateRunspacePool(1, $MaxRunspace, $RunspaceConnectionInfo)       
25:	        $RunspacePool.Open()				
26:		   					
27:	        $aryPowerShell  = New-Object System.Collections.ArrayList
28:	        $aryIAsyncResult  = New-Object System.Collections.ArrayList
29:	        for ( $i = 0; $i -lt $MaxRunspace; $i++ )		
30:	        {						
31:	            $Cmd = $Cmds[$i]				
32:	            $PowerShell = [PowerShell]::Create()		
33:	            $PowerShell.RunspacePool = $RunspacePool	
34:	            $PowerShell.AddScript($Cmd)			
35:	            $PowerShell.AddCommand("Out-String")		
36:	            $IAsyncResult = $PowerShell.BeginInvoke()	
37:	                      				
38:	            $aryPowerShell.Add($PowerShell)		
39:	            $aryIAsyncResult.Add($IAsyncResult)		
40:	        }						
41:							
42:	        while ( $aryPowerShell.Count -gt 0 )		
43:	        {						
44:	            for ( $i = 0; $i -lt $aryPowerShell.Count; $i++ )	
45:	            {					
46:	                $PowerShell = $aryPowerShell[$i]		
47:	                $IAsyncResult = $aryIAsyncResult[$i]   	
48:							
49:	                if($PowerShell -ne $null)		
50:	                {					
51:	                    if($IAsyncResult.IsCompleted)		
52:	                    {				
53:	                        $Result = $PowerShell.EndInvoke($IAsyncResult)
54:	                        Write-host $Result		
55:	                        $PowerShell.Dispose()		
56:	                        $aryPowerShell.RemoveAt($i)	
57:	                        $aryIAsyncResult.RemoveAt($i)	
58:	                        {break outer}			
59:	                    }				
60:	                }          				
61:	            }					
62:	            Start-Sleep -Milliseconds 100		
63:	        }						
64:	    } catch [Exception] {				
65:	        Write-Host $_.Exception.Message;		
66:	    } finally {					
67:	        $RunspacePool.Close()				
68:	    }						
69:	}						 

  1:      '非同期のコマンド指定
   2:      Dim strAsyncCmds() As String = {"Export-VM ?Name VM01 ?Path D:\Exp", "Start-VM VM02", "Get-VM", "Start-VM VM03"}
   3:   
   4:      'コマンドを実行
   5:      AsyncPowershell(strServer, strAccount, strPassword, strAsyncCmds)
   6:   
   7:      Public Sub AsyncPowershell(ByVal strServer As String, ByVal strAccount As String, ByVal strPassword As String, ByVal strCmds() As String)
   8:          Dim objRunspacePool As RunspacePool = Nothing
   9:          Try
  10:              'パスワードを暗号化
  11:              Dim objSecureString As New SecureString()
  12:              For Each c As String In strPassword.ToCharArray()
  13:                  objSecureString.AppendChar(c)
  14:              Next
  15:              Dim objPSCredential As New PSCredential(strAccount, objSecureString)
  16:   
  17:              'WinRMを利用してリモートでPowerShellを実行
  18:              Dim objUri As New Uri("http://" + strServer + ":5985/wsman")
  19:              Dim objWSManConnectionInfo As New WSManConnectionInfo(objUri, "http://schemas.microsoft.com/powershell/Microsoft.PowerShell", objPSCredential)
  20:   
  21:              Dim intRunspace As Integer = strCmds.Length
  22:              objRunspacePool = RunspaceFactory.CreateRunspacePool(1, intRunspace, objWSManConnectionInfo)
  23:              'objRunspacePool.ApartmentState = Threading.ApartmentState.STA
  24:              'objRunspacePool.ThreadOptions = PSThreadOptions.UseNewThread
  25:              objRunspacePool.Open()
  26:   
  27:              Dim aryPowerShell As New ArrayList
  28:              Dim aryIAsyncResult As New ArrayList
  29:              Dim strCmd As String = ""
  30:              For i As Integer = 0 To strCmds.Length - 1
  31:                  strCmd = strCmds(i)
  32:   
  33:                  Dim objPowerShell As PowerShell = PowerShell.Create()
  34:                  objPowerShell.RunspacePool = objRunspacePool
  35:                  objPowerShell.AddScript(strCmd)
  36:                  objPowerShell.AddCommand("Out-String")
  37:                  'PowerShellコマンド実行
  38:                  Dim objIAsyncResult As IAsyncResult = objPowerShell.BeginInvoke()
  39:   
  40:                  aryPowerShell.Add(objPowerShell)
  41:                  aryIAsyncResult.Add(objIAsyncResult)
  42:              Next
  43:   
  44:              Do While (aryPowerShell.Count > 0)
  45:                  For i As Integer = 0 To aryPowerShell.Count - 1
  46:   
  47:                      Dim objPowerShell As PowerShell = aryPowerShell(i)
  48:                      Dim objIAsyncResult As IAsyncResult = aryIAsyncResult(i)
  49:   
  50:                      If Not IsNothing(objPowerShell) Then
  51:                          If objIAsyncResult.IsCompleted Then
  52:                              Dim objResultCollection As PSDataCollection(Of PSObject) = objPowerShell.EndInvoke(objIAsyncResult)
  53:   
  54:                              'PowerShellコマンドの実行結果を出力
  55:                              For Each objResult As PSObject In objResultCollection
  56:                                  Debug.WriteLine(objResult.ToString)
  57:                              Next
  58:   
  59:                              'PowerShellのエラーを出力
  60:                              Dim objErrors As Collection(Of ErrorRecord) = objPowerShell.Streams.Error.ReadAll
  61:                              For Each objErrorRecord As ErrorRecord In objErrors
  62:                                  Debug.WriteLine(objErrorRecord.Exception.Message)
  63:                              Next
  64:   
  65:                              objPowerShell.Dispose()
  66:                              aryPowerShell.RemoveAt(i)
  67:                              aryIAsyncResult.RemoveAt(i)
  68:                              Exit For
  69:                          End If
  70:                      End If
  71:   
  72:                  Next
  73:                  Threading.Thread.Sleep(100)
  74:              Loop
  75:          Catch ex As Exception
  76:              Debug.WriteLine(ex.ToString)
  77:          Finally
  78:              objRunspacePool.Close()
  79:          End Try
  80:      End Sub

 1:      //非同期のコマンド指定
   2:      string[] strAsyncCmds = {"Export-VM ?Name VM01 ?Path D:\\Exp", "Start-VM VM02", "Get-VM", "Start-VM VM03"};
   3:         
   4:      //コマンドを実行
   5:      AsyncPowershell(strServer, strAccount, strPassword, strAsyncCmds);
   6:   
   7:      static void AsyncPowershell(string strServer, string strAccount, string strPassword, string[] strCmds)
   8:      {
   9:          //パスワードを暗号化
  10:          SecureString objSecureString = new SecureString();
  11:          foreach (char c in strPassword.ToCharArray()) { objSecureString.AppendChar(c); }
  12:          PSCredential objPSCredential = new PSCredential(strAccount, objSecureString);
  13:   
  14:          //WinRMを利用してリモートでPowerShellを実行
  15:          Uri objUri = new Uri("http://" + strServer + ":5985/wsman");
  16:          WSManConnectionInfo objWSManConnectionInfo = new WSManConnectionInfo(objUri, "http://schemas.microsoft.com/powershell/Microsoft.PowerShell", objPSCredential);
  17:   
  18:          int intRunspace = strCmds.Length;
  19:          using (RunspacePool objRunspacePool = RunspaceFactory.CreateRunspacePool(1, intRunspace, objWSManConnectionInfo))
  20:          {
  21:              //objRunspacePool.ApartmentState = Threading.ApartmentState.STA
  22:              //objRunspacePool.ThreadOptions = PSThreadOptions.UseNewThread
  23:              objRunspacePool.Open();
  24:   
  25:              ArrayList aryPowerShell = new ArrayList();
  26:              ArrayList aryIAsyncResult = new ArrayList();
  27:              string strCmd = "";
  28:              for (int i = 0; i <= strCmds.Length - 1; i++)
  29:              {
  30:                  strCmd = strCmds[i];
  31:   
  32:                  PowerShell objPowerShell = PowerShell.Create();
  33:                  objPowerShell.RunspacePool = objRunspacePool;
  34:                  objPowerShell.AddScript(strCmd);
  35:                  objPowerShell.AddCommand("Out-String");
  36:                  //PowerShellコマンド実行
  37:                  IAsyncResult objIAsyncResult = objPowerShell.BeginInvoke();
  38:   
  39:                  aryPowerShell.Add(objPowerShell);
  40:                  aryIAsyncResult.Add(objIAsyncResult);
  41:              }
  42:   
  43:              while ((aryPowerShell.Count > 0))
  44:              {
  45:   
  46:                  for (int i = 0; i <= aryPowerShell.Count - 1; i++)
  47:                  {
  48:                      PowerShell objPowerShell = (PowerShell)aryPowerShell[i];
  49:                      IAsyncResult objIAsyncResult = (IAsyncResult)aryIAsyncResult[i];
  50:   
  51:                      if ((objPowerShell != null))
  52:                      {
  53:                          if (objIAsyncResult.IsCompleted)
  54:                          {
  55:                              PSDataCollection<PSObject> objResultCollection = objPowerShell.EndInvoke(objIAsyncResult);
  56:   
  57:                              //PowerShellコマンドの実行結果を出力
  58:                              foreach (PSObject objResult in objResultCollection)
  59:                              {
  60:                                  Debug.WriteLine(objResult.ToString());
  61:                              }
  62:   
  63:                              //PowerShellのエラーを出力
  64:                              Collection<ErrorRecord> objErrors = objPowerShell.Streams.Error.ReadAll();
  65:                              foreach (ErrorRecord objErrorRecord in objErrors)
  66:                              {
  67:                                  Debug.WriteLine(objErrorRecord.Exception.Message);
  68:                              }
  69:   
  70:                              objPowerShell.Dispose();
  71:                              aryPowerShell.RemoveAt(i);
  72:                              aryIAsyncResult.RemoveAt(i);
  73:                              break;
  74:                          }
  75:                      }
  76:                  }
  77:                  System.Threading.Thread.Sleep(100);
  78:              }
  79:          }
  80:      }