運維開發：python websocket網頁實時顯示遠程服務器日誌信息

時間  2019-12-18
標籤 開發 python websocket 網頁 實時 顯示 遠程 服務器 日誌 信息 欄目 Python 简体版
原文   原文鏈接

功能：用websocket技術，在運維工具的瀏覽器上實時顯示遠程服務器上的日誌信息javascript

通常咱們在運維工具部署環境的時候，須要實時展示部署過程當中的信息，或者在瀏覽器中實時顯示程序日誌給開發人員看。你還在用ajax每隔段時間去獲取服務器日誌？out了，試試用websocket方式吧html

我用bottle框架，寫了個websocket服務端，瀏覽器鏈接到websocket server，再用python subprocess獲取遠程服務器的日誌信息，subprocess，就是用Popen調用shell的shell命令而已，這樣能夠獲取到實時的日誌了，而後再send到websocket server中，那鏈接到websocket server的瀏覽器，就會實時展示出來了html5

用二臺服務器來實現這個場景，A服務器是websocket服務端，B服務器是日誌端java

A服務器是我瀏覽器本機，websocket服務端也是這臺機，IP是：192.168.1.221python

B服務器是要遠程查看日誌的服務器，我這裏用：192.168.1.10jquery

如下是A服務器的websocket servet的python代碼：linux

 
  1. #!/usr/bin/env python
  2. #coding=utf-8
  3. # __author__ = '戴儒鋒'
  4. # http://www.linuxyw.com
  6. """
  7.     執行代碼前須要安裝
  8.     pip install bottle
  9.     pip install websocket-client
  10.     pip install bottle-websocket
  11. """
  12. from bottle import get, run
  13. from bottle.ext.websocket import GeventWebSocketServer
  14. from bottle.ext.websocket import websocket
  16. users = set()   # 鏈接進來的websocket客戶端集合
  17. @get('/websocket/', apply=[websocket])
  18. def chat(ws):
  19.     users.add(ws)
  20.     while True:
  21.         msg = ws.receive()  # 接客戶端的消息
  22.         if msg:
  23.             for u in users:
  24.                 u.send(msg) # 發送信息給全部的客戶端
  25.         else:
  26.             break
  27.     # 若是有客戶端斷開鏈接，則踢出users集合
  28.     users.remove(ws)
  29. run(host='0.0.0.0', port=8000, server=GeventWebSocketServer)

記得安裝bottle、websocket-client 、bottle-websocket 模塊，服務端容許全部的IP訪問其8000端口nginx

 

websocket服務端除了用以上的方法外，還能夠用這下面的方法實現：web

使用gevent-websocket實現websocket服務端程序ajax

 

在電腦桌面，寫一個簡單的HTML5  javascripts頁面，隨便命名了，如web_socket.html，這個頁面使用了websocket鏈接到websocket服務端：

 
  1.  <!DOCTYPE html>
  2. <html>
  3. <head>
  4. </head>
  5.     <style>
  6.         #msg{
  7.             width:400px; height:400px; overflow:auto; border:2px solid #000000;color:#ffffff;
  8.     }
  9.     </style>
  10. </head>
  12. <body>
  13.     <p>實時日誌</p>
  14.     <div id="msg"></div>
  15.     <script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>
  16.     <script>
  17.     $(document).ready(function() {
  18.         /* !window.WebSocket、window.MozWebSocket檢測瀏覽器對websocket的支持*/
  19.         if (!window.WebSocket) {
  20.             if (window.MozWebSocket) {
  21.                 window.WebSocket = window.MozWebSocket;
  22.             } else {
  23.                 $('#msg').prepend("<p>你的瀏覽器不支持websocket</p>");
  24.             }
  25.         }
  27.         /* ws = new WebSocket 建立WebSocket的實例  注意設置對如下的websocket的地址哦*/
  28.         ws = new WebSocket('ws://192.168.1.221:8000/websocket/');
  30.         /*
  31.             ws.onopen  握手完成並建立TCP/IP通道，當瀏覽器和WebSocketServer鏈接成功後，會觸發onopen消息
  32.             ws.onmessage 接收到WebSocketServer發送過來的數據時，就會觸發onmessage消息，參數evt中包含server傳輸過來的數據;
  33.         */
  34.         ws.onopen = function(evt) {
  35.             $('#msg').append('<li>websocket鏈接成功</li>');
  36.         }
  37.         ws.onmessage = function(evt) {
  38.             $('#msg').prepend('<li>' + evt.data + '</li>');
  39.         }
  40.     });
  41. </script>
  42. </body>
  43. </html>

注意：WebSocket('ws://192.168.1.221:8000/websocket/');  這裏的192.168.1.221必定要改爲你的websocket服務端IP，切記！！！

到這裏，就搞定瀏覽器鏈接到websocket服務端的場景了，如今要A服務器裏寫一段代碼，去採集B服務器的實時信息了，其實採集原理很簡單，就是使用shell中的tailf命令，實時顯示最新的信息而已，咱們在這段腳本中，使用subprocess.Popen()來遠程查看日誌信息：

python代碼以下：

 
  1. #!/usr/bin/python
  2. # encoding=utf-8
  4. import subprocess
  5. import time
  6. from websocket import create_connection
  8. # 配置遠程服務器的IP，賬號，密碼，端口等，因我作了雙機密鑰信任，因此不須要密碼
  9. r_user = "root"
  10. r_ip = "192.168.1.10"
  11. r_port = 22
  12. r_log = "/tmp/web_socket.log"   # 遠程服務器要被採集的日誌路徑
  14. # websocket服務端地址
  15. ws_server = "ws://192.168.1.221:8000/websocket/"
  17. # 執行的shell命令（使用ssh遠程執行）
  18. cmd = "/usr/bin/ssh -p {port} {user}@{ip} /usr/bin/tailf {log_path}".format(user=r_user,ip=r_ip,port=r_port,log_path=r_log)
  20. def tailfLog():
  21.     """獲取遠程服務器實時日誌，併發送到websocket服務端"""
  22.     popen = subprocess.Popen(cmd,stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)
  23.     print('鏈接成功')
  24.     ws = create_connection(ws_server)   # 建立websocket鏈接
  25.     while True:
  26.         line = popen.stdout.readline().strip()  #獲取內容
  27.         if line:
  28.             ws.send(line)   #把內容發送到websocket服務端
  29.         print time.time()
  31. if __name__ == '__main__':
  32.     tailfLog()

文章最後再解析subprocess.Popen的原理和功能

執行websocket服務端腳本和上面這個websocket客戶端採集腳本，再打開用瀏覽器打開上面的html5頁面後，環境就基本部署好了，雙websocket客戶端鏈接到websocket服務端中

上面腳本指定的r_log = "/tmp/web_socket.log"日誌路徑，咱們須要生成這個日誌文件，並不停地往裏面寫入日誌，這樣才能在瀏覽器中實時顯示效果（真實場景中，能夠指定服務器某日誌，如apache,nginx日誌等）

咱們在B服務器寫一段python代碼，而後每隔一秒就往r_log = "/tmp/web_socket.log"日誌中寫入內容：

python代碼以下：

 
  1. #!/usr/bin/env python
  2. #coding=utf-8
  4. import time
  5. import random
  6. log_path = '/tmp/web_socket.log'
  7. while 1:
  8.     with open(log_path,'a') as f:
  9.         f.write('[%s]   %s \n' % (time.ctime(),random.random()))
  10.     time.sleep(1)

腳本寫入的內容大概是：

[Tue Jul 26 18:30:41 2016] 0.527242649654 
[Tue Jul 26 18:30:42 2016] 0.21080845298 
[Tue Jul 26 18:30:43 2016] 0.23128691356 
[Tue Jul 26 18:30:44 2016] 0.689547600796

執行這段腳本，而後看瀏覽器效果：

websocket實時日誌效果

 

這只是我臨時寫的，若是要在真實的運維工具中使用，還須要根據具體狀況，修改很多內容，但原理就是這樣，你們可根據本身的狀況修改，完善使用。

 

剛纔提到subprocess.Popen的原理和功能，請看如下資料：

http://www.cnblogs.com/fengbeihong/articles/3374132.html

bottle websocket參考資料：

http://rfyiamcool.blog.51cto.com/1030776/1269232/

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程