Cmdlet详细流

Question

我目前正在使用PowerShell 5.0 SDK编写C＃cmdlet。

我试图将“第三方可执行文件的StandardError”管道从“实时”从powershell运行时输出到cmdlet输出。

我目前使用MedallionShell库来处理运行过程。我已经用普通的C＃win窗体尝试了这一点，并使用Command.StandardError.PipeToAsync（Console.OpenStandardOutput（））来获取打印输出，因为可执行文件以“实时”方式将其生成到控制台。

我试图创建我自己的Stream对象，它调用WriteVerbose，但它似乎没有打印任何东西到powershell屏幕（我正在传递-Verbose到cmdlet，当我运行它）。

我的电流看起来是这样的：

1. 打开PowerShell ISE中
2. 加载我模块（C＃DLL）
3. 叫我的cmdlet和参数
   • Command.Run
   • Command.StandardError.PipeToAsync（???）
   • Command.Wait（在此步骤中，o输出应该流向PowerShell窗口）
   • 检查Command.Result.Success。

任何人都可以点我在这个正确的方向？

Answer 1

您不能从任意线程调用Cmdlet的Write方法（如WriteVerbose）。您需要将对此方法的调用编组回到管道线程。一种方法是实现消息循环，当其他线程想要在管道线程中调用某些东西时，它将处理来自其他线程的消息。

Add-Type @‘ 
    using System; 
    using System.Collections.Concurrent; 
    using System.Diagnostics; 
    using System.Management.Automation; 
    using System.Threading; 
    [Cmdlet(VerbsLifecycle.Invoke, "Process")] 
    public class InvokeProcessCmdlet : Cmdlet { 
     [Parameter(Position = 1)] 
     public string FileName { get; set; } 
     [Parameter(Position = 2)] 
     public string Arguments { get; set; } 
     protected override void EndProcessing() { 
      using(BlockingCollection<Action> messageQueue = new BlockingCollection<Action>()) { 
       using(Process process = new Process { 
        StartInfo=new ProcessStartInfo(FileName, Arguments) { 
         UseShellExecute=false, 
         RedirectStandardOutput=true, 
         RedirectStandardError=true 
        }, 
        EnableRaisingEvents=true 
       }) { 
        int numberOfCompleteRequests = 0; 
        Action complete =() => { 
         if(Interlocked.Increment(ref numberOfCompleteRequests)==3) { 
          messageQueue.CompleteAdding(); 
         } 
        }; 
        process.OutputDataReceived+=(sender, args) => { 
         if(args.Data==null) { 
          complete(); 
         } else { 
          messageQueue.Add(() => WriteObject(args.Data)); 
         } 
        }; 
        process.ErrorDataReceived+=(sender, args) => { 
         if(args.Data==null) { 
          complete(); 
         } else { 
          messageQueue.Add(() => WriteVerbose(args.Data)); 
         } 
        }; 
        process.Exited+=(sender, args) => complete(); 
        process.Start(); 
        process.BeginOutputReadLine(); 
        process.BeginErrorReadLine(); 
        foreach(Action action in messageQueue.GetConsumingEnumerable()) { 
         action(); 
        } 
       } 
      } 
     } 
    } 
’@ -PassThru | Select-Object -First 1 -ExpandProperty Assembly | Import-Module 

你还可以用这样的测试：

Invoke-Process icacls 'C:\* /c' -Verbose