91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

python如何實現統計osd-pg并導出到csv

發布時間:2021-11-15 23:33:45 來源:億速云 閱讀:193 作者:柒染 欄目:云計算

python如何實現統計osd-pg并導出到csv,針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

分析當前集群各個OSD的pg分布情況

import json
from collections import OrderedDict
import csv
import subprocess

def get_pg_dump():
    cmd = "ceph pg dump --format=json"
    out = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE)
    result = out.stdout.readlines()[1].split('\n')[0]
    return result

csv_file = './demo.csv' #生成的csv文件路徑

pg_data = json.loads(get_pg_dump())
pg_dict = {}
osd_pg_dict = {}

for i in pg_data:
    for j in  pg_data['pg_stats']:
        pg_dict[j['pgid']] = j['up']

pool_pg_total = {}
osd_pg_num_dict = {}
tmp_pool_list = {}
tmp_osd_list = {}
start_osd = 0
start_pool_id = 0
all_result = {}

for i in pg_dict:
    pool_id =  int(i.split('.')[0])
    for osd_id in pg_dict[i]:
        tmp_pool_list[pool_id] = pool_id
        tmp_osd_list[osd_id] = osd_id

num_pool = max(tmp_pool_list.iterkeys(), key=lambda k: tmp_pool_list[k]) + 1
num_osd = max(tmp_osd_list.iterkeys(), key=lambda k: tmp_osd_list[k]) + 1
pool_totol_pg = [0] * num_pool
max_osd_list = [0] * num_pool
min_osd_list = [999] * num_pool
max_osdid_list = ['No_OSD'] * num_pool
min_osdid_list = ['No_OSD'] * num_pool
ave_osd_list = [0] * num_pool
ave_osd_list_result = [0] * num_pool
min_osd_per_list = [0] * num_pool
max_osd_per_list = [0] * num_pool

for i in range(0,num_osd):
    keyname = str(i)
    all_result[keyname] = [0] * num_pool

for i in pg_dict:
    pool_id = int(i.split('.')[0])
    for osd_id in pg_dict[i]:
        tmp_keyname = str(osd_id)
        tmp_list =  all_result[tmp_keyname]
        tmp_list[pool_id] = tmp_list[pool_id] +1

for i in all_result:
    tmp_num = 0
    for j in all_result[i]:
        if j < min_osd_list[tmp_num] and j != 0:
            min_osd_list[tmp_num] = j
            min_osdid_list[tmp_num] = i
        if j > max_osd_list[tmp_num]:
            max_osd_list[tmp_num] = j
            max_osdid_list[tmp_num] = i
        if j != 0:
            ave_osd_list[tmp_num] = ave_osd_list[tmp_num] + 1
        pool_totol_pg[tmp_num] = pool_totol_pg[tmp_num] + j
        tmp_num = tmp_num + 1

for i in range(0,len(ave_osd_list)):
    if ave_osd_list[i] != 0:
        ave_osd_list_result[i] = pool_totol_pg[i]/ave_osd_list[i]

all_result =  OrderedDict(sorted(all_result.items(), key=lambda t: int(t[0])))

for i in range(0,num_pool):
    if max_osd_list[i] != 0:
        max_osd_per_list[i] = round(100*(max_osd_list[i]-ave_osd_list_result[i])/float(ave_osd_list_result[i]),2)

for i in range(0, num_pool):
    if min_osd_list[i] != 999:
        min_osd_per_list[i] = round(100 * (min_osd_list[i] - ave_osd_list_result[i])/float(ave_osd_list_result[i]),2)

with open(csv_file, 'w') as csvfile:
    pool_list = []
    for i in range(0,num_pool):
        pool_list.append('pool-'+str(i))
    fieldnames = ['osd_name'] + pool_list + ['total']
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    for i in all_result:
        tmp_dict = {'osd_name': i,'total':sum(all_result[i])}
        tmp_num = 0
        for j in all_result[i]:
            keyname = 'pool-' + str(tmp_num)
            tmp_num = tmp_num + 1
            tmp_dict[keyname] = j
        writer.writerow(tmp_dict)
    fieldnames = ['SUM'] + pool_totol_pg + [sum(pool_totol_pg)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['AVE'] + ave_osd_list_result + [sum(ave_osd_list_result)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MAX'] + max_osd_list + [sum(max_osd_list)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MAX-OSD-ID'] + max_osdid_list
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MAX-PER'] + max_osd_per_list + [sum(max_osd_per_list)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MIN'] + min_osd_list + [sum(min_osd_list)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MIN-OSD-ID'] + min_osdid_list
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()
    fieldnames = ['MIN-PER'] + min_osd_per_list + [sum(min_osd_per_list)]
    writer = csv.DictWriter(csvfile, fieldnames=fieldnames)
    writer.writeheader()

print '---------------------------------------------------------------------------'
for i in  all_result:
    print i,all_result[i],sum(all_result[i])
print '---------------------------------------------------------------------------'
print 'SUM',pool_totol_pg
print 'MAX',max_osd_list
print 'MIN-OSD-ID',max_osdid_list
print 'MIN',min_osd_list
print 'MIN-OSD-ID',min_osdid_list
print 'AVE',ave_osd_list_result
print 'MIN-PER',min_osd_per_list
print 'MAX-PER',max_osd_per_list

關于python如何實現統計osd-pg并導出到csv問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業資訊頻道了解更多相關知識。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

明光市| 沅陵县| 工布江达县| 安庆市| 渑池县| 竹溪县| 偃师市| 北票市| 司法| 百色市| 卢氏县| 锡林郭勒盟| 镇坪县| 潜山县| 隆回县| 普格县| 水富县| 昂仁县| 眉山市| 潼关县| 佛冈县| 新沂市| 临江市| 汪清县| 北辰区| 竹北市| 德格县| 莒南县| 天津市| 永福县| 昔阳县| 康马县| 滁州市| 嵩明县| 晋城| 建水县| 吕梁市| 武威市| 始兴县| 阜康市| 四平市|