rulemsiFlushMonStat.r

def main(rule_args, callback, rei):
    time = irods_rule_vars['*Time'][1:-1]
    table = irods_rule_vars['*Table'][1:-1]
    cpu_weight = irods_rule_vars['*Cpuw'][1:-1]
    mem_weight = irods_rule_vars['*Memw'][1:-1]
    swap_weight = irods_rule_vars['*Swapw'][1:-1]
    run_queue_weight = irods_rule_vars['*Runw'][1:-1]
    disk_weight = irods_rule_vars['*Diskw'][1:-1]
    network_in_weight = irods_rule_vars['*Netinw'][1:-1]
    network_out_weight = irods_rule_vars['*Netow'][1:-1]

    callback.msiFlushMonStat(time, table)
    callback.msiDigestMonStat(cpu_weight, mem_weight, swap_weight, run_queue_weight, disk_weight, network_in_weight, network_out_weight)

    ret_val = callback.msiExecStrCondQuery('SELECT SLD_RESC_NAME, SLD_LOAD_FACTOR', irods_types.GenQueryOut())
    genQueryOut = ret_val['arguments'][1]

    for row in range(genQueryOut.rowCnt):
        resc_name = genQueryOut.sqlResult[0].row(row)
        load_factor = genQueryOut.sqlResult[1].row(row)
        callback.writeLine('stdout', resc_name + ' = ' + load_factor)

INPUT *Time="24", *Table="serverLoad", *Cpuw="1", *Memw="1", *Swapw="0", *Runw="0", *Diskw="0", *Netinw="1", *Netow="1"
OUTPUT ruleExecOut