django+tornado实现实时查看远程日志的方法

django+tornado实现实时查看远程日志的方法实现实时查看远程日志的方法

今天小编就为大家分享一篇django+tornado实现实时查看远程日志的方法，具有很好的参考价值，希望对大家

有所帮助。一起跟随小编过来看看吧

大致思路：大致思路：

1.利用tornado提供的websocket功能与浏览器建立长连接，读取实时日志并输出到浏览器

2.写一个实时读取日志的脚本，利用saltstack远程执行，并把实时日志发往redis中。

3.tornado读取redis中的信息，发往浏览器。

此过程用到了redis的发布和订阅功能。

import redis

import salt.client

from tornado import gen

from tornado.escape import to_unicode

from logs.utility import get_last_lines

from logs import settings

class SubWebSocket(tornado.websocket.WebSocketHandler):

"""

此handler处理远程日志查看

"""

local = salt.client.LocalClient()

r = redis.StrictRedis(host=settings.REDIS_HOST, port=settings.REDIS_PORT,

password=settings.REDIS_PASSWD, db=5)

# 订阅频道，服务器和日志路径确定一个频道

key = settings.LOG_KEY.format(server=hostname.strip(), log_path=log_path.strip())

channel = r.pubsub()

channel.subscribe(key)

# 异步方式执行命令，远程运行脚本

local.cmd_async(hostname, "cmd.run", [cmd])

try:

if data["type"] == "message":

line = format_line(data["data"])

self.write_message(line)

except tornado.websocket.WebSocketClosedError:

self.close()

def on_close(self):

global FLAG

FLAG = False

print("closed")

def format_line(line):