Question Gestion d'une file d'attente

PE2012 écrit:

je n'arrive pas à appeler un script qui définira les taches

Il est peut être sourd d'oreille

Comme tu ne nous communiques pas le msg d'erreur, on peut supposer qu'il s'agit d'un pb de jeux de paramètre.
Précise soit -Filepath soit -Scriptblock, mais pas les deux en même temps. Un problème de 'double bind'

Une ébauche :
[code:1]
Function Split-MagJobName {
#Parse le nom d'un Job et renvoi un objet
param ($MagJobName)

$Nom,$Date=$MagJobName -split \"\\\"
New-Object PSObject -Property @{Magasin=($Nom -Replace \"^MAG\",\"\"«»);
StartTime=([DateTime]::FromBinary($Date));
State=$Null;
Name=$MagJobName #Nom du job utilisé par Stop-Job
}
}

Function New-Magasin {
param(
[String]$NomMag,
[String]$NumMag
)
New-Object PsObject -property @{
Nom=$NomMag;
Numero=$NumMag;
DebutReplication=$Null;
FinReplication=$null
}
}

$Path=\"C:\Temp\TraitementDunMagasin.ps1\"

@\"
Sleep (Get-Random -Maximum 3 -Minimum 1)
return (Get-Random -Maximum 2 -Minimum 0)
\"@ > $Path

$Queue = New-object system.collections.queue


$Nom='Paris'
$Magasin1=New-Magasin $Nom 9
$Magasin2=New-Magasin 'Marseille' 21
$Magasin3=New-Magasin 'Lyon' 55

$Magasin1,$Magasin2,$Magasin3 |
Foreach-Object {
#$Queue.Enqueue($_)
$MagasinCourant=$_
$StartDate=[DateTime]::Now
$MagasinCourant.DebutReplication=$StartDate
$JobName=\"MAG$($_.Nom)\$($StartDate.ToBinary())\"
Start-Job -FilePath $Path -ArgumentList $JobName -Name $JobName
}

Get-Job|Foreach {Split-MagJobName $_.Name}
[/code:1]<br><br>Message édité par: Laurent Dardenne, à: 27/08/12 21:47

La précédente version de l'ébauche du script, prudence,prudence, portait implicitement, on y arrive, l'usage de la 'quiou' dans ce contexte.

Une solution, utilisant cette queue, basée sur le post suivant :
[code:1]
Function Split-MagJobName {
#Parse le nom d'un Job et renvoi un objet
param ($MagJobName)

$Nom,$Date=$MagJobName -split \&quot;\\\&quot;
New-Object PSObject -Property @{Magasin=($Nom -Replace \&quot;^MAG\&quot;,\&quot;\&quot;«»);
StartTime=([DateTime]::FromBinary($Date));
State=$Null;
Name=$MagJobName #Nom du job utilisé par Stop-Job
}
}

Function New-Magasin {
param(
[String]$NomMag,
[String]$NumMag
)
New-Object PsObject -property @{
Nom=$NomMag;
Numero=$NumMag;
DebutReplication=$Null;
FinReplication=$null;
Success=$null
}
}

$Path=\&quot;C:\Temp\TraitementDunMagasin.ps1\&quot;

@'
param($Magasin)
Write-host \&quot;Traite le magasin situé à $($Magasin.Nom)\&quot; -Fore White
Sleep -Seconds (Get-Random -Maximum 3 -Minimum 1)
$result=(Get-Random -Maximum 2 -Minimum 0) -as [Boolean]
if ($result )
{Write-host \&quot;Réussite du traitement du magasin situé à $($Magasin.Nom)\&quot; -Fore Green}
else
{Write-host \&quot;Echec du traitement du magasin situé à $($Magasin.Nom)\&quot; -Fore Red}
$Magasin.FinReplication=[DateTime]::Now
$Magasin.Success=$Result
return $Magasin
'@ &gt; $Path


$Magasins=@(
(New-Magasin 'Paris' 9),
(New-Magasin 'Marseille' 21),
(New-Magasin 'Lyon' 55),
(New-Magasin 'Lille' 123),
(New-Magasin 'Bordeaux' 1985),
(New-Magasin 'Toulouse' 6),
(New-Magasin 'Brest' 1),
(New-Magasin 'Strasbourg' 33),
(New-Magasin 'Clermont' 66)
)

# How many jobs we should run simultaneously
$maxConcurrentJobs = 3;
$Queue = [System.Collections.Queue]::«»Synchronized( (New-Object System.Collections.Queue) )

foreach($Mag in $Magasins)
{ $Queue.Enqueue($Mag) }

# Function that pops input off the queue and starts a job with it
function Start-JobFromQueue
{
if( $Queue.Count -gt 0)
{
$MagasinCourant=$Queue.Dequeue()
$StartDate=[DateTime]::Now
$MagasinCourant.DebutReplication=$StartDate
$JobName=\&quot;MAG$($MagasinCourant.Nom)\$($StartDate.ToBinary())\&quot;

$CurrentJob = Start-Job -FilePath $Path -ArgumentList $MagasinCourant -Name $JobName
Register-ObjectEvent -InputObject $CurrentJob -EventName StateChanged -SourceIdentifier \&quot;Event$JobName\&quot; -Action {
Start-JobFromQueue
Unregister-Event $eventsubscriber.SourceIdentifier
Remove-Job $eventsubscriber.SourceIdentifier
} | Out-Null
}
}

# Start up to the max number of concurrent jobs
# Each job will take care of running the rest
for( $i = 0; $i -lt $maxConcurrentJobs; $i++ )
{
Start-JobFromQueue
}

sleep -Seconds (1*60)
$MagasinsResultat=Get-Job|Where-Object {$_.Name -Match \&quot;^MAG\&quot;}|Receive-Job -keep
[/code:1]
Je n'ai pas commenté, c'est à ta charge
En tout cas l'implémentation de ton besoin est trés instructif. Si je peux je la mettrais à profit dans une prochaine session de formation PS dispensée en interne dans mon entreprise
Merci.<br><br>Message édité par: Laurent Dardenne, à: 28/08/12 23:02

Il reste qq soucis avec le dernier exemple.
Par exemple si un job crash.
Si, si ça arrive

Sans trop rentrer dans les détails, l'usage de la classe Queue, en considérant les crash, n'est peut être pas suffisant pour gérer le résultat des jobs.

Ensuite la présence de l'heure de démarrage n'a d'intérêt que si tu souhaites gérer un temps max d'exécution du job, avant sa suppression automatique( un timeout sur le job). A prioris tu n'en as pas besoin.

Bref, cela demande encore qq réflexions