Scripts/ProtectionJob/Get-CohesityProtectionJobStatus.ps1
|
class ProtectionJobStatus { [String]$jobName [Boolean]$remoteCopy [int]$jobId $startTime $estimatedTime [double]$percentCompleted ProtectionJobStatus(){} ProtectionJobStatus( [String]$jobName, [Boolean]$remoteCopy, [int]$jobId, $startTime, $estimatedTime, [double]$percentCompleted ){ $this.jobName = $jobName $this.remoteCopy = $remoteCopy $this.jobId = $jobId $this.startTime = $startTime $this.estimatedTime = $estimatedTime $this.percentCompleted = $percentCompleted } [string]ToString(){ return $this | Select-Object -Property * } [string]GetEstimatedTime() { $ts = [timespan]::fromseconds($this.estimatedTime) return ("{0:hh\:mm\:ss\ }" -f $ts) } [string]GetStartTime() { if($this.startTime -eq 0) { return "0" } $ret = ([DateTimeOffset]::FromUnixTimeSeconds($this.startTime)).DateTime.ToLocalTime() return $ret.ToString() } } function Get-CohesityProtectionJobStatus { [CmdletBinding()] Param( ) Begin { if(-not (Test-Path -Path "$HOME/.cohesity")) { throw "Failed to authenticate. Please connect to the Cohesity Cluster using 'Connect-CohesityCluster'" } $session = Get-Content -Path $HOME/.cohesity | ConvertFrom-Json $server = $session.ClusterUri $token = $session.Accesstoken.Accesstoken } Process { $url = $server + '/irisservices/api/v1/public/protectionJobs?isDeleted=false' $headers = @{'Authorization'='Bearer '+$token} $resp = Invoke-RestApi -Method 'Get' -Uri $url -Headers $headers $jobIdAndName = @{} $activeJobIds = New-Object System.Collections.ArrayList ForEach ($item in $resp) { $r = $activeJobIds.Add($item.id) $jobIdAndName.Add($item.id,$item.name) } $jobIdAndRemoteStatus = @{} $url = $server + '/irisservices/api/v1/public/protectionRuns' $resp = Invoke-RestApi -Method 'Get' -Uri $url -Headers $headers foreach ($item in $resp) { if($item.backupRun.status -eq "kSuccess") { if($false -eq $jobIdAndRemoteStatus.ContainsKey($item.jobId)) { $r = $jobIdAndRemoteStatus.Add($item.jobId, $false) } } else { $remoteStatus = $false foreach ($status in $item.copyRun) { if($status.target.type -eq "kRemote") { $remoteStatus = $true break } } $jobIdAndRemoteStatus[$item.jobId] = $remoteStatus } } $protectionJobStatusList = @() $activeTasks = New-Object System.Collections.ArrayList $url = $server + '/irisservices/api/v1/backupjobssummary?_includeTenantInfo=true&allUnderHierarchy=true&includeJobsWithoutRun=true&isDeleted=false&numRuns=1000&onlyReturnBasicSummary=true&onlyReturnJobDescription=false' $resp = Invoke-RestApi -Method 'Get' -Uri $url -Headers $headers ForEach ($item in $resp) { if($activeJobIds.Contains($item.backupJobSummary.jobDescription.jobId)) { if($item.backupJobSummary.lastProtectionRun.backupRun.base.publicStatus -notin "kSuccess" -AND $null -notlike $item.backupJobSummary.lastProtectionRun.backupRun.activeAttempt.base.progressMonitorTaskPath) { $r = $activeTasks.Add($item.backupJobSummary.lastProtectionRun.backupRun.activeAttempt.base.progressMonitorTaskPath) } else { [ProtectionJobStatus]$status = [ProtectionJobStatus]::new( $jobIdAndName[$item.backupJobSummary.jobDescription.jobId], $false, $item.backupJobSummary.jobDescription.jobId, 0, 0, 100 ) $protectionJobStatusList += $status } } } foreach ($item in $activeTasks) { $url = $server + '/irisservices/api/v1/progressMonitors?=excludeSubTasks=true&includeFinishedTasks=true&taskPathVec='+$item $resp = Invoke-RestApi -Method 'Get' -Uri $url -Headers $headers $task = $resp.resultGroupVec[0].taskVec[0].progress $jobName = "" $jobId = 0 $startTimeUsecs = 0 foreach ($jobAttrib in $resp.resultGroupVec[0].taskVec[0].progress.attributeVec) { if($jobAttrib.key -eq "job_name") { $jobName = $jobAttrib.value.data.stringValue } if($jobAttrib.key -eq "job_id") { $jobId = $jobAttrib.value.data.stringValue } if($jobAttrib.key -eq "start_time_usecs") { $startTimeUsecs = $jobAttrib.value.data.stringValue } } $remoteJobStatus = $false foreach($entry in $jobIdAndRemoteStatus.Keys) { if($jobId -eq $entry) { $remoteJobStatus = $jobIdAndRemoteStatus[$entry] break } } [ProtectionJobStatus]$status = [ProtectionJobStatus]::new( $jobName, $remoteJobStatus, $jobId, $task.startTimeSecs, $task.expectedTimeRemainingSecs, $task.percentFinished ) $protectionJobStatusList += $status } $columnWidth = 20 $protectionJobStatusList | Sort-Object -Property startTime -Descending | Format-Table @{ Label='ID'; Expression={$_.jobId};}, @{ Label='NAME'; Expression={$_.jobName}; Width=$columnWidth; }, @{ Label='REMOTE COPY'; Expression={$_.remoteCopy}; Width=$columnWidth }, @{ Label='STARTED AT'; Expression={$_.GetStartTime()}; Width=$columnWidth }, @{ Label='ESTIMATED TIME'; Expression={$_.GetEstimatedTime()};Width=$columnWidth }, @{ Label='COMPLETED(%)'; Expression={$_.percentCompleted}; Width=$columnWidth } } End { } } |