如何启动job foreach ip和coostiate ip for文件名称

Question

我有一个脚本来自在这里这是工作：

function CaptureWeight {
    Start-Job -Name WeightLog -ScriptBlock {
        filter timestamp {
            $sw.WriteLine("$(Get-Date -Format MM/dd/yyyy_HH:mm:ss) $_")
        }

        try {
            $sw = [System.IO.StreamWriter]::new("$using:LogDir\$FileName$(Get-Date -f MM-dd-yyyy).txt")
            & "$using:PlinkDir\plink.exe" -telnet $using:SerialIP -P $using:SerialPort | TimeStamp
        }
        finally {
            $sw.ForEach('Flush')
            $sw.ForEach('Dispose')
        }
    }
}

i' D希望让他违反IP地址列表，同时还具有与IP关联的名称来设置每个文件的文件名。我在想 $ name = myFilename 和 $ name.ip = 1.1.1.1 以及使用$ filename和$ serialip的东西，但尚未能够让任何接近工作或找到足够接近我想要的示例的示例。

谢谢

Answer 1

这是您可以用 hash表 AS theo 在他的帮助评论中提到。请注意，没有阈值/therottlelimit参数与 start-threadjob 或 由于作业在不同的过程中运行，因为您已经评论了/ runspaces ，没有内置的方式来控制多少个工作可以在同时。如果您愿意控制这个，则需要自己编码。

# define IPs as Key and FileName as Value
$lookup = @{
    '1.2.3.4'      = 'FileNameForThisIP'
    '192.168.1.15' = 'AnotherFileNameForTHatIP'
}

# path to directory executable
$plink = 'path\to\plinkdirectory'
# path to log directory
$LogDir = 'path\to\logDirectory'
# serial port
$serialport = 123

$jobs = foreach($i in $lookup.GetEnumerator()) {
    Start-Job -Name WeightLog -ScriptBlock {
        filter timestamp {
            $sw.WriteLine("$(Get-Date -Format MM/dd/yyyy_HH:mm:ss) $_")
        }
        
        try {
            $path = Join-Path $using:LogDir -ChildPath ('{0}{1}.txt' -f $using:i.Value, (Get-Date -f MM-dd-yyyy))
            $sw = [System.IO.StreamWriter]::new($path)
            $sw.AutoFlush = $true
            & "$using:plink\plink.exe" -telnet $using:i.Key -P $using:serialPort | TimeStamp
        }
        finally {
            $sw.ForEach('Dispose')
        }
    }
}

$jobs | Receive-Job -AutoRemoveJob -Wait

哈希表的另一种替代方法可能是使用CSV（要么来自 import-csv 或用 conversfrom-csv ）。

Answer 2

在此处添加我以前答案的另一种选择，使用 runspacepool 实例具有内置的一种并发和重新启动的方式。

using namespace System.Management.Automation.Runspaces

try {
    # define number of threads that can run at the same time
    $threads = 10

    # define IPs as Key and FileName as Value
    $lookup = @{
        '1.2.3.4'      = 'FileNameForThisIP'
        '192.168.1.15' = 'AnotherFileNameForTHatIP'
    }

    # path to directory executable
    $plink  = 'path\to\plinkdirectory\'
    # path to log directory
    $LogDir = 'path\to\logDirectory'
    # serial port
    $port   = 123

    $iss    = [initialsessionstate]::CreateDefault2()
    $rspool = [runspacefactory]::CreateRunspacePool(1, $threads, $iss, $Host)
    $rspool.ApartmentState = 'STA'
    $rspool.ThreadOptions  = 'ReuseThread'

    # session variables that will be intialized with the runspaces
    $rspool.InitialSessionState.Variables.Add([SessionStateVariableEntry[]]@(
        [SessionStateVariableEntry]::new('plink', $plink, '')
        [SessionStateVariableEntry]::new('serialport', $port, '')
        [SessionStateVariableEntry]::new('logDir', $LogDir, '')
    ))
    $rspool.Open()

    $rs = foreach($i in $lookup.GetEnumerator()) {
        $ps = [powershell]::Create().AddScript({
            param($pair)

            filter timestamp {
                $sw.WriteLine("$(Get-Date -Format MM/dd/yyyy_HH:mm:ss) $_")
            }

            try {
                $path = Join-Path $LogDir -ChildPath ('{0}{1}.txt' -f $pair.Value, (Get-Date -f MM-dd-yyyy))
                $sw = [System.IO.StreamWriter]::new($path)
                $sw.AutoFlush = $true

                & "$plink\plink.exe" -telnet $pair.Key -P $serialPort | TimeStamp
            }
            finally {
                $sw.ForEach('Dispose')
            }
        }).AddParameter('pair', $i)

        $ps.RunspacePool = $rspool

        @{
            Instance    = $ps
            AsyncResult = $ps.BeginInvoke()
        }
    }

    foreach($r in $rs) {
        try {
            $r.Instance.EndInvoke($r.AsyncResult)
            $r.Instance.Dispose()
        }
        catch {
            Write-Error $_
        }
    }
}
finally {
    $rspool.ForEach('Dispose')
}