是否可以从筛选器中终止或停止PowerShell管道

2lpgd968  于 2023-05-29  发布在  Shell
关注(0)|答案(8)|浏览(149)

我已经编写了一个简单的PowerShell过滤器,如果当前对象的日期在指定的开始和结束日期之间,则将其推送到管道中。从管道中下来的对象总是按日期升序排列的,所以只要日期超过指定的结束日期,我就知道我的工作已经完成了,我想告诉管道上游命令可以放弃他们的工作,这样管道就可以完成它的工作。我正在阅读一些非常大的日志文件,我经常只想检查日志的一部分。我很确定这是不可能的,但我想问一下。

e7arh2l6

e7arh2l61#

可以使用任何会中断外部循环或完全停止脚本执行(如抛出异常)的东西来中断管道。解决方案是将管道 Package 在一个循环中,如果需要停止管道,可以中断该循环。
例如,下面的代码将返回管道中的第一项,然后通过中断外部do-while循环来中断管道:

do {
    Get-ChildItem|% { $_;break }
} while ($false)

这个功能可以 Package 成这样的函数,其中最后一行完成与上面相同的事情:

function Breakable-Pipeline([ScriptBlock]$ScriptBlock) {
    do {
        . $ScriptBlock
    } while ($false)
}

Breakable-Pipeline { Get-ChildItem|% { $_;break } }
ghg1uchk

ghg1uchk2#

无法从下游命令停止上游命令。它将继续过滤掉不符合条件的对象,但第一个命令将处理它设置要处理的所有内容。
解决方法是在上游cmdlet或function/filter上执行更多筛选。使用日志文件会使它变得有点复杂,但是使用Select-String和正则表达式来过滤掉不需要的日期可能对您有用。
除非你知道你想要多少行和从哪里开始,否则整个文件将被读取以检查模式。

cwtwac6a

cwtwac6a3#

下面是Stop-Pipeline cmdlet(需要PS v3+)的一个不完美的实现,它是从this answer改编而来的:

#requires -version 3
Filter Stop-Pipeline {
  $sp = { Select-Object -First 1 }.GetSteppablePipeline($MyInvocation.CommandOrigin)
  $sp.Begin($true)
  $sp.Process(0)
}

# Example
1..5 | % { if ($_ -gt 2) { Stop-Pipeline }; $_ } # -> 1, 2

警告:我不完全理解它是如何工作的,尽管它从根本上利用了Select -First过早停止管道的能力(PS v3+)。然而,在这种情况下,Select -First终止管道的方式有一个关键的区别:*下游 * cmdlet(管道中 * 稍后 * 的命令)没有机会运行其end块。

因此,聚合cmdlet(必须接收 * 所有 * 输入才能产生输出的cmdlet,如Sort-ObjectGroup-ObjectMeasure-Object如果稍后放置在同一管道中,将不会产生输出;例如:

# !! NO output, because Sort-Object never finishes.
1..5 | % { if ($_ -gt 2) { Stop-Pipeline }; $_ } | Sort-Object

背景信息,可能导致更好的解决方案:

多亏了PetSerAl,我的answer here展示了如何生成Select-Object -First在内部用来停止上游cmdlet的相同异常。
但是,在那里,从 * 本身连接到要停止的管道 * 的cmdlet内部抛出异常,这里不是这种情况:
上面例子中使用的Stop-Pipeline * 没有 * 连接到应该停止的流水线(只有外围的ForEach-Object%)块连接到了),所以问题是:如何在目标管道的上下文中引发异常?

3lxsmp7m

3lxsmp7m4#

结束管道时可以引发异常。

gc demo.txt -ReadCount 1 | %{$num=0}{$num++; if($num -eq 5){throw "terminated pipeline!"}else{write-host $_}}


看看这篇关于如何终止管道的文章:https://web.archive.org/web/20160829015320/http://powershell.com/cs/blogs/tobias/archive/2010/01/01/cancelling-a-pipeline.aspx

bqujaahr

bqujaahr5#

不确定您的确切需求,但可能值得您花时间研究一下Log Parser,看看是否可以在数据到达管道之前使用查询来过滤数据。

6psbrbz9

6psbrbz96#

如果你愿意使用非公共成员,这里是一种停止管道的方法。它模仿了select-object的功能。invoke-method(别名im)是一个调用非公共方法的函数。select-property(别名selp)是一个选择(类似于select-object)非公共属性的函数,但是如果只找到一个匹配的属性,它会自动像-ExpandProperty一样工作。(我在工作中写了select-propertyinvoke-method,所以不能分享它们的源代码)。

# Get the system.management.automation assembly
$script:smaa=[appdomain]::currentdomain.getassemblies()|
         ? location -like "*system.management.automation*"
# Get the StopUpstreamCommandsException class 
$script:upcet=$smaa.gettypes()| ? name -like "*StopUpstreamCommandsException *"

function stop-pipeline {
    # Create a StopUpstreamCommandsException
    $upce = [activator]::CreateInstance($upcet,@($pscmdlet))

    $PipelineProcessor=$pscmdlet.CommandRuntime|select-property PipelineProcessor
    $commands = $PipelineProcessor|select-property commands
    $commandProcessor= $commands[0]

    $ci = $commandProcessor|select-property commandinfo
    $upce.RequestingCommandProcessor | im set_commandinfo @($ci)

    $cr = $commandProcessor|select-property commandruntime
    $upce.RequestingCommandProcessor| im set_commandruntime @($cr)

    $null = $PipelineProcessor|
        invoke-method recordfailure @($upce, $commandProcessor.command)

    if ($commands.count -gt 1) {
      $doCompletes = @()
      1..($commands.count-1) | % {
        write-debug "Stop-pipeline: added DoComplete for $($commands[$_])"
        $doCompletes += $commands[$_] | invoke-method DoComplete -returnClosure
      }
      foreach ($DoComplete in $doCompletes) {
        $null = & $DoComplete
      }
    }

    throw $upce
}

编辑:根据mklement 0的评论:
这里是一个link的Nivot墨水博客上的一个脚本上的“戳”模块,同样给予访问非公共成员。
至于其他评论,我在这一点上没有有意义的。这段代码只是模仿了select-object的反编译所揭示的内容。原始的MS注解(如果有的话)当然不在反编译中。坦率地说,我不知道函数使用的各种类型的目的。要达到这样的理解水平可能需要相当大的努力。
我的建议是:拿到奥辛的戳模块调整代码以使用该模块。然后尝试一下。如果你喜欢它的工作方式,那么就使用它,不要担心它是如何工作的(这就是我所做的)。
注意:我没有深入研究过“poke”,但我猜它没有任何类似-returnClosure的东西。然而,添加应该很容易,因为这:

if (-not $returnClosure) {
  $methodInfo.Invoke($arguments)
} else {
  {$methodInfo.Invoke($arguments)}.GetNewClosure()
}
wljmcqd8

wljmcqd87#

尝试这些过滤器,它们会强制管道在第一个对象或前n个元素后停止,并将其存储在变量中;你需要传递变量的名字,如果你不这样做,对象(s)被推出,但不能被分配给变量。

filter FirstObject ([string]$vName = '') {
 if ($vName) {sv $vName $_ -s 1} else {$_}
 break
}

filter FirstElements ([int]$max = 2, [string]$vName = '') {
 if ($max -le 0) {break} else {$_arr += ,$_}
 if (!--$max) {
  if ($vName) {sv $vName $_arr -s 1} else {$_arr}
  break
 }
}

# can't assign to a variable directly
$myLog = get-eventLog security | ... | firstObject

# pass the the varName
get-eventLog security | ... | firstObject myLog
$myLog

# can't assign to a variable directly
$myLogs = get-eventLog security | ... | firstElements 3

# pass the number of elements and the varName
get-eventLog security | ... | firstElements 3 myLogs
$myLogs

####################################

get-eventLog security | % {
 if ($_.timegenerated -lt (date 11.09.08) -and`
  $_.timegenerated -gt (date 11.01.08)) {$log1 = $_; break}
}

#
$log1
z4bn682m

z4bn682m8#

另一种选择是在switch语句上使用-file参数。使用-file将一次读取一行文件,您可以使用break立即退出,而无需阅读文件的其余部分。

switch -file $someFile {
  # Parse current line for later matches.
  { $script:line = [DateTime]$_ } { }
  # If less than min date, keep looking.
  { $line -lt $minDate } { Write-Host "skipping: $line"; continue }
  # If greater than max date, stop checking.
  { $line -gt $maxDate } { Write-Host "stopping: $line"; break }
  # Otherwise, date is between min and max.
  default { Write-Host "match: $line" }
}

相关问题