telegraf

awsmetric2series.py

from __future__ import print_function

import json
import re
import sys

def snake_case(name):
    name = name.replace('/', '_')
    s1 = re.sub('(.)([A-Z][a-z]+)', r'\1_\2', name)
    return re.sub('([a-z0-9])([A-Z])', r'\1_\2', s1).lower()

j = json.load(sys.stdin)

for m in j['Metrics']:
    print('cloudwatch_'+snake_case(m['Namespace']), end='')
    d = [ snake_case(dim['Name'])+'='+dim['Value'] for dim in m['Dimensions'] ]
    if len(d) > 0:
        print(','+','.join(d), end='')
    print(' ', end='')
    print(snake_case(m['MetricName']+'_average'))