Python-сообщество

# -*- coding: utf-8 -*-
import os
import json
import re
import tempfile
import subprocess
import sys
import time
import fileinput
from sensu_plugin import SensuPluginMetricGraphite
from datetime import datetime
#class CephMetrics(SensuPluginMetricGraphite):
data = {
        'rd': 0,
        'rd KB': 0,
        'wr': 0,
        'wr KB': 0,
        'time':0
        }
work_data = {
        'rd': 0,
        'rd KB': 0,
        'wr': 0,
        'wr KB': 0,
        'time':0
        }
new_data = {
        'rd': 0,
        'rd KB': 0,
        'wr': 0,
        'wr KB': 0,
        'time':0
        }
#    def run(self):
#        mass_slovar = []
first_data = False
tmp_file = tempfile.gettempdir() + '/' + 'ceph.stats.tmp'
mode = 'r+' if os.path.exists(tmp_file) else 'w+'
prev_data_file = open(tmp_file, mode)
try:
    old_data = json.loads(''.join(prev_data_file.readlines()))
except ValueError:
    first_data = True
#old_data = work_data
old_time = old_data['time']
print ("old time", old_time)
atime = str(time.time())
now_time = ("%d" % (float(atime)))
print ("new time", now_time)
time_difference = (int(now_time) - int(old_time))
print ("time difference %d %s" %(time_difference, 'seconds'))
print ("\n")
c = subprocess.Popen("rados df".split(" "), stdout=subprocess.PIPE, stderr=subprocess.PIPE)
text = c.stdout.read()
for textline in text.split("\n"):
    stline = textline.strip()
    if len(stline) > 1 and not stline.startswith('pool') and not stline.startswith('total'):
        stline = re.split("\s+", stline)
#########где-то здесь должен быть более ровный код
######### текущему словарю new_data присваивается по два значения,которые мне по хорошему бы разбить и просуммировать/вычесть
        new_data = {
            'rd': stline[6],
            'rd KB': stline[7],
            'wr': stline[8],
            'wr KB': stline[9],
            'time': now_time
                    }
        print "\n"
        print new_data
   
        if not first_data:
            for k in work_data:
                try:
                    work_data[k] = (int(new_data[k]) - int(old_data[k]))
                except KeyError:
                    work_data[k] = 0
            #print ("new time", now_time)
            print ("\n")
            print ("old data", old_data)
            print ("\n")
            print ("new data", new_data)
            print ("\n")
            PoolName = stline[0]
            print ('PoolName: ',PoolName)
            for k in work_data:
                print ('   ' + k + '     ', work_data[k])
            print ("\n")
            readspeed = work_data['rd KB']
            writespeed = work_data['wr KB']
            readops = work_data['rd']
            writeops = work_data['wr']
            if work_data['rd KB'] > 0:
                print("average read speed for the last %d %s %d %s" %(time_difference, " seconds is ", ((readspeed / time_difference)), "bytes/s"))
                print("total %d %s %d %s" %(readops, "read operations for last ", time_difference, " seconds"))
                print("total %d %s" %((readops/time_difference), " read op/s"))
                print "%5.2f" % (readops/time_difference)
            else:
                print('no read operations for the last time')
            print ("\n")
            if (work_data['wr KB']) > 0:
                print("average write speed for the last %d %s %d %s" %(time_difference, " seconds is ", ((writespeed / time_difference)), "bytes/s"))
                print("total %d %s %d %s" %(writeops, "write operations for last ",time_difference, " seconds"))
                print("total ???? %d %s" %((writeops/time_difference), " write op/s"))
                print "%5.2f" % (writeops/time_difference)
            else:
                print('no write operations for the last time')
            #print "\n
prev_data_file.seek(0)
prev_data_file.write(json.dumps(new_data))
prev_data_file.truncate()
prev_data_file.close()

import fileinput

print ("\n")

# -*- coding: utf-8 -*-
import os
import json
import re
import tempfile
import subprocess
import time
data = {
    'rd': 0,
    'rd KB': 0,
    'wr': 0,
    'wr KB': 0,
    'time': 0
}
work_data = {
    'rd': 0,
    'rd KB': 0,
    'wr': 0,
    'wr KB': 0,
    'time': 0
}
new_data = {
    'rd': 0,
    'rd KB': 0,
    'wr': 0,
    'wr KB': 0,
    'time': 0
}
first_data = False
tmp_file = tempfile.gettempdir() + '/' + 'ceph.stats.tmp'
mode = 'r+' if os.path.exists(tmp_file) else 'w+'
prev_data_file = open(tmp_file, mode)
try:
    old_data = json.loads(''.join(prev_data_file.readlines()))
except ValueError:
    first_data = True
#old_data = data
old_time = old_data['time']
print ("old time", old_time)
atime = str(time.time())
now_time = ("%d" % (float(atime)))
print ("new time", now_time)
time_difference = (int(now_time) - int(old_time))
print ("time difference %d %s" % (time_difference, 'seconds'))
print ("\n")
c = subprocess.Popen("rados df".split(" "), stdout=subprocess.PIPE, stderr=subprocess.PIPE)
text = c.stdout.read()
for textline in text.split("\n"):
    stline = textline.strip()
    if len(stline) > 1 and not stline.startswith('pool') and not stline.startswith('total'):
        stline = re.split("\s+", stline)
        new_data = {
            'rd': stline[6],
            'rd KB': stline[7],
            'wr': stline[8],
            'wr KB': stline[9],
            'time': now_time
        }
        print ("old data", old_data)
        print ("new data", new_data)
        if not first_data:
            for k in work_data:
                try:
                    work_data[k] = (int(new_data[k]) - int(old_data[k]))
                except KeyError:
                    work_data[k] = 0
        PoolName = stline[0]
        print ('PoolName: ', PoolName)
        for k in work_data:
            print ('   ' + k + '     ', work_data[k])
prev_data_file.seek(0)
prev_data_file.write(json.dumps(new_data))
prev_data_file.truncate()
prev_data_file.close()

# -*- coding: utf-8 -*-
import os
import subprocess
c = subprocess.Popen("rados df".split(" "), stdout=subprocess.PIPE, stderr=subprocess.PIPE)
text = c.stdout.read()
for textline in text.split("\n"):
    stline = textline.strip()
    if len(stline) > 1 and not stline.startswith('pool') and not stline.startswith('total'):
        stline = re.split("\s+", stline)
        print ("11111111111", stline[1].split())   #вот эта команда выводит злополучные две строки

import os
import json
import subprocess
import tempfile
def main(file_name="ceph.stats.tmp"):
    output = subprocess.check_output(["rados", "df"])
    # все столбцы таблицы, подставить правильные
    field_names = ['rd', 'rd KB', 'wr', 'wr KB', 'time']
    # названия, которые нужно игнорировать
    ignore_field_names = []
    file_path = os.path.join(tempfile.gettempdir(), file_name)
    if os.path.isfile(file_path):
        with open(file_path) as f:
            old_data = json.load(f)
    else:
        old_data = {}
        
    for line in output.splitlines()[1:-3]:
        splitted_line = line.split()
        pool_name = splitted_line[0]
        data = {
            name: int(value) for name, value in zip(field_names, splitted_line[1:])
            if name not in ignore_field_names
        }
        work_data = {}  # нам нужна work_data
        # здесь обновляются данные из old_data
        if old_data and pool_name in old_data:
            for key in data:
                work_data[key] = data[key] - old_data[pool_name][key]
                
                # old_data[pool_name][key] = ...
        else:
            old_data[pool_name] = data
    with open(file_path, "w") as f:
        json.dump(old_data, f)
if __name__ == "__main__":
    main()

# -*- coding: utf-8 -*-
import os
import json
import subprocess
import tempfile
def main(file_name="ceph.stats.tmp"):
    output = subprocess.check_output(["rados", "df"])
    # все столбцы таблицы, подставить правильные
    field_names = ['rd', 'rd KB', 'wr', 'wr KB', 'time']
    # названия, которые нужно игнорировать
    ignore_field_names = ['KB', 'objects', 'clones', 'degrated', 'unfound']
    file_path = os.path.join(tempfile.gettempdir(), file_name)
    if os.path.isfile(file_path):
        with open(file_path) as f:
            old_data = json.load(f)
    else:
        old_data = {}
    for line in output.splitlines()[1:-3]:
        splitted_line = line.split()
        pool_name = splitted_line[0]
        data = {
            name: int(value) for name, value in zip(field_names, splitted_line[1:])
            if name not in ignore_field_names
        }
        work_data = {}  # нам нужна work_data
        # здесь обновляются данные из old_data
        if old_data and pool_name in old_data:
            for key in data:
                work_data[key] = data[key] - old_data[pool_name][key]
                # old_data[pool_name][key] = ...
                  #непонятно что здесь писать....
        else:
            old_data[pool_name] = data
    with open(file_path, "w") as f:
        json.dump(old_data, f)
if __name__ == "__main__":
    main()

n1      n2
типа    такого
типа    такого
типа    такого