"""獲取各指標(卡頓、點播、直播、**丟包、
二層丟幀、斷流、記憶體、rtp丟包)
不同**型別(mditype=點播、高畫質直播、
2k高畫質直播、4k高畫質直播、epg頁面)的質差使用者數與總使用者數的比值
時間段:2018-5-24 6:10
通過索引m-stb統計使用者總數，
通過iptv-monitor-m-gather-apk-yyyymmdd 獲取各指標質差使用者數
南充111000
廣安113000
"""獲取不同指標型別的**丟包質差使用者數
:param
time_: 索引時間
:param
localnet_id: 本地網id
:param
field: **丟包欄位
:param
value: **丟包衡量質差標準
:param
start: 開始時間
:param
end: 結束時間
:return
:"""
index_ = "iptv-monitor-m-gather-apk--".format(time_, localnet_id)
try:
rs = es.search(index=index_,
body=
}},}},}
}}}]
}},
"aggs": ,
"aggs": ,
"aggs": ,
"aggs": }}
}}}}
}}
})return rs
except:
return -1
def
get_m_stb_usr_account(localnet_id):
"""獲取本地網對應的總使用者數
:param
localnet_id:
:return
:"""
index_ = "m-stb"
try:
rs = es.search(index=index_,
body=}},
"aggs": }}
})return rs['aggregations']['1']['value']
except:
return -1
def
get_iptv_monitor_m(time_, localnet_id, field, value, start, end):
"""獲取各個指標對應的質差使用者數
:param
time_: 索引時間
:param
localnet_id: 本地網id
:param
field: 指標字段
:param
value: 衡量指標質差的值
:param
start: 開始時間
:param
end: 結束時間
:return
:"""
if field.upper() == "mdimlr".upper():
try:
rs = get_iptv_monitor_m_mlr(time_, localnet_id, field, value, start, end)
return rs
except:
return -1
index_ = "iptv-monitor-m-gather-apk--".format(time_, localnet_id)
try:
rs = es.search(index=index_,
body=
}},}},}
}]}},
"aggs": ,
"aggs": ,
"aggs": ,
"aggs": }}
}}}}
}}
})return rs
except:
return -1
def
kind_dict():
"""八個指標及對應的指標值
:return
:"""
dict_ =
return dict_
if __name__ == '__main__':
time_ = "20180524"
# 南充 111000 廣安 113000
localnet_ids = ["111000"
, "113000"]
# 南充總使用者數 廣安總使用者數
total_usr = [南充總使用者數, 廣安總使用者數]
start = "2018-05-24 18:00"
end = "2018-05-24 22:00"
i = 0
for localnet_id in localnet_ids:
localnet_id = localnet_id.strip()
path = "e:
\\公司
\\案例資料採集
\\olt告警案例分析
\\\\
".format(time_, localnet_id)
if os.path.exists(path):
pass
else:
os.makedirs(path)
for key, value_dict in kind_dict().items():
field = key
value = value_dict
write_fact_path = "e:
\\公司
\\案例資料採集
\\olt告警案例分析
\\\\
\\__alarm.txt".format(time_, localnet_id, field)
# total_usr = get_m_stb_usr_account(localnet_id)
total_usr = total_usr[i]
rs = get_iptv_monitor_m(time_, localnet_id, field, value, start, end)
with
open(write_fact_path,
"w") as f:
dict_key = {}
for hit in rs['aggregations']['1']['2']['buckets']:
key = hit['key']
value = hit['3']['4']['value']
dict_key.setdefault(key, value)
for i in
range(6):
value_ = dict_key.get(str(i))
if value_ is none:
value_ = 0
value_2 = round(value_ / total_usr,
6) f.write(str(value_2) + ",")
f.write("
\n")
f.close()
i += 1
日誌分析告警平台 ELK ZABBIX的組合實踐
最近在給公司用elk搭建日誌分析平台，搭建成功之後，發現elk 缺少乙個重要功能模組，即告警功能。於是乎有尋覓到了與elk 無縫整合的外掛程式x pack 但是，但是，但是它是收費的。為了將開源到底，於是乎我們想了很多辦法 1.尋找x pack 替代外掛程式，例如kaae或者sentinl，發現這兩...
綜合日誌分析系統 綜合告警系統
日誌審計輸出 日誌審計系統通過三個途徑向審計人員提供審計能力 實時告警 分析報告 事件查詢 實時告警 日誌審計系統實時監控網路及安全裝置 系統平台的安全訪問和各種效能狀態，並進行實時分析記錄，出現不符合預定規則就應該通過裝置遠端主控台 簡訊 郵件 語音提示 qq msn等方式向審計人員傳送實時告警訊...
SeedFill 連通區域分析
two pass方法計算二值圖連通域效率比較低，補充下seed filling種子填充法，該方法類似於圖的深度搜素。為了提高效率，做了一點修改。針對新標籤的第乙個畫素，其鄰域只選取下方和後方未處理的畫素 針對處理過的畫素新增識別符號，下次再碰到該畫素時，可直接跳過。判斷鄰域座標，防止越界。具體 bo...