Pipeline Duration

pipeline_duration.py

#!/bin/python
#aws codepipeline list-pipeline-executions --pipeline-name spectre-prod>codepipeline.json
import json
import sys
import dateutil.parser as parser
import datetime

data = json.load(sys.stdin)
total = 0
count = 0
print("pipelineExecutionId,startTime,lastUpdateTime,DurationInSeconds,DurationInMinutes")
for record in data['pipelineExecutionSummaries']:
    if record['status'] == 'Succeeded':
        count = count + 1
        lastUpdateTime = parser.parse(record['lastUpdateTime'])
        startTime = parser.parse(record['startTime'])
        diff = lastUpdateTime - startTime
        diff_in_seconds = diff.total_seconds()
        total = total + diff_in_seconds
        diff_in_minutes = diff_in_seconds / 60
        print("%s,%s,%s,%s,%s" % (record['pipelineExecutionId'],startTime.strftime("%d/%m/%Y %H:%M"),lastUpdateTime.strftime("%d/%m/%Y %H:%M"),diff_in_seconds, diff_in_minutes))