Cmdlet verbose stream

Question

J'écris actuellement une cmdlet C# en utilisant le SDK PowerShell 5.0.

J'essaie de diriger l'erreur StandardError d'un exécutable tiers vers la sortie cmdlet lorsqu'elle est exécutée à partir de powershell en "temps réel". J'utilise actuellement la bibliothèque MedallionShell pour gérer l'exécution du processus. J'ai essayé ceci avec un formulaire de gain C# normal et j'ai utilisé Command.StandardError.PipeToAsync (Console.OpenStandardOutput()) pour obtenir la sortie à imprimer car l'exécutable l'a généré sur la console en "temps réel".

J'ai essayé de créer mon propre objet Stream qui appelle WriteVerbose mais il n'a pas semblé imprimer quoi que ce soit à l'écran powershell (je passe -Verbose à cmdlet quand je l'exécute).

Mon flux actuel ressemble à ceci:

1. Ouvert Powershell ISE
2. Charger mon module (dll C#)
3. Call my cmdlet avec des paramètres
   • Command.Run
   • Command.StandardError.PipeToAsync (???)
   • Command.Wait (Au cours de cette étape, o l'entrée doit être transférée à la fenêtre powershell)
   • Vérifiez Commande.Résult.Succès.

Quelqu'un peut-il me diriger dans la bonne direction à ce sujet?

Answer 1

Vous ne pouvez pas simplement appeler Cmdlet les méthodes Write (comme WriteVerbose) à partir d'un thread arbitraire. Vous devez rassembler les appels à cette méthode vers le thread de pipeline. Un moyen de le faire est d'implémenter une boucle de message, qui traiterait les messages provenant d'autres threads, lorsque d'autres threads veulent invoquer quelque chose dans un thread de pipeline.

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 

Et vous pouvez le tester avec quelque chose comme ceci:

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