contrib/add_host_powerunit_info.py

#! /usr/bin/python

"""
Add power unit information to host attributes.

Usage:
    ./contrib/add_host_powerunit_info.py --csv mapping_file.csv

Each line in mapping_file.csv consists of
device_hostname, powerunit_hostname, powerunit_outlet, hydra_hostname,
seperated by comma. For example

chromeos-rack2-host1,chromeos-rack2-rpm1,.A1,chromeos-197-hydra1.mtv
chromeos-rack2-host2,chromeos-rack2-rpm1,.A2,chromeos-197-hydra1.mtv
...

"""
import argparse
import csv
import logging
import os
import sys

import common

from autotest_lib.server.cros.dynamic_suite import frontend_wrappers
from autotest_lib.site_utils.rpm_control_system import utils as rpm_utils


AFE = frontend_wrappers.RetryingAFE(timeout_min=5, delay_sec=10)

# The host attribute key name for get rpm hostname.
POWERUNIT_KEYS = [rpm_utils.POWERUNIT_HOSTNAME_KEY,
                  rpm_utils.POWERUNIT_OUTLET_KEY,
                  rpm_utils.HYDRA_HOSTNAME_KEY]


def add_powerunit_info_to_host(device, keyvals):
    """Add keyvals to the host's attributes in AFE.

    @param device: the device hostname, e.g. 'chromeos1-rack1-host1'
    @param keyvals: A dictionary where keys are the values in POWERUNIT_KEYS.
                    These are the power unit info about the devcie that we
                    are going to insert to AFE as host attributes.
    """
    logging.info('Adding host attribues to %s: %s', device, keyvals)
    for key, val in keyvals.iteritems():
        AFE.set_host_attribute(key, val, hostname=device)


def add_from_csv(csv_file):
    """Read power unit information from csv and add to host attributes.

    @param csv_file: A csv file, each line consists of device_hostname,
                     powerunit_hostname powerunit_outlet, hydra_hostname
                     separated by comma.
    """
    with open(csv_file) as f:
        reader = csv.reader(f, delimiter=',')
        for row in reader:
            device = row[0].strip()
            hydra = row[3].strip()
            if not hydra:
                hydra = None
            keyvals = dict(zip(
                    POWERUNIT_KEYS,
                    [row[1].strip(), row[2].strip(), hydra]))
            add_powerunit_info_to_host(device, keyvals)


if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG)
    parser = argparse.ArgumentParser(
            description='Add power unit information to host attributes.')
    parser.add_argument('--csv', type=str, dest='csv_file',
                        help='A path to a csv file, each line consists of '
                             'device_name, powerunit_hostname, '
                             'powerunit_outlet, hydra_hostname, separated '
                             'by comma.')
    options = parser.parse_args()
    if not options.csv_file:
        logging.error('Must specify a csv-style mapping file by --csv.')
        sys.exit(1)
    if not os.path.exists(options.csv_file):
        logging.error('%s is not a valid file.', options.csv_file)
        sys.exit(1)
    add_from_csv(options.csv_file)