Mars Xlog windows环境使用实践

作者: 多一点童真 | 来源:发表于2020-12-02 15:44 被阅读0次

Mars Xlog windows环境使用实践
聊聊微信 Xlog
XLog 详解及源码分析
微信Mars——Xlog使用
平安好房iOS开发团队技术周报（第三十四期）
Mars-日志模块xlog for React-Native (
腾讯Mars-Xlog日志解析报错- No module nam
iOS 接入xlog
微信Mars——xlog使用全解析
需要学习文章

准备工作：python2.7环境，通过git克隆mars项目

注意： marxlog 脚本decode_mars_crypt_log_file.py 目前只能在python2+环境里执行，在python3+环境脚本语法不支持，需要修改。
在python2.7执行发现一些无效的导入，导致执行报错，修改后可行。我这边是把xlog文件拷贝到和脚本在相同目录，切换到目录执行 Cpython decode_mars_crypt_log_file.py ***.xlog 命令，就可以查看了。

修改后是这样的，替换 mars\mars\log\crypt\decode_mars_crypt_log_file.py 内容。

!/usr/bin/python

import sys
import os
import glob
import zlib
import struct
import binascii

import pyelliptic

import traceback

import zstandard as zstd

MAGIC_NO_COMPRESS_START = 0x03
MAGIC_NO_COMPRESS_START1 = 0x06
MAGIC_NO_COMPRESS_NO_CRYPT_START = 0x08
MAGIC_COMPRESS_START = 0x04
MAGIC_COMPRESS_START1 = 0x05
MAGIC_COMPRESS_START2 = 0x07
MAGIC_COMPRESS_NO_CRYPT_START = 0x09

MAGIC_SYNC_ZSTD_START = 0x0A;
MAGIC_SYNC_NO_CRYPT_ZSTD_START = 0x0B;
MAGIC_ASYNC_ZSTD_START = 0x0C;
MAGIC_ASYNC_NO_CRYPT_ZSTD_START = 0x0D;

MAGIC_END = 0x00

lastseq = 0

class ZstdDecompressReader:
def init(self, buffer):
self.buffer = buffer

def read(self, size):
    return self.buffer

PRIV_KEY = "145aa7717bf9745b91e9569b80bbf1eedaa6cc6cd0e26317d810e35710f44cf8"
PUB_KEY = "572d1e2710ae5fbca54c76a382fdd44050b3a675cb2bf39feebe85ef63d947aff0fa4943f1112e8b6af34bebebbaefa1a0aae055d9259b89a1858f7cc9af9df1"

def tea_decipher(v, k):
op = 0xffffffffL
v0, v1 = struct.unpack('=LL', v[0:8])
k1, k2, k3, k4 = struct.unpack('=LLLL', k[0:16])
delta = 0x9E3779B9
s = (delta << 4) & op
for i in xrange(16):
v1 = (v1 - (((v0<<4) + k3) ^ (v0 + s) ^ ((v0>>5) + k4))) & op
v0 = (v0 - (((v1<<4) + k1) ^ (v1 + s) ^ ((v1>>5) + k2))) & op
s = (s - delta) & op
return struct.pack('=LL', v0, v1)

def tea_decrypt(v, k):
num = len(v) / 8 * 8
ret = ''
for i in xrange(0, num, 8):
x = tea_decipher(v[i:i+8], k)
ret += x

ret += v[num:]
return ret

def IsGoodLogBuffer(_buffer, _offset, count):

if _offset == len(_buffer): return (True, '')

magic_start = _buffer[_offset] 
if MAGIC_NO_COMPRESS_START==magic_start or MAGIC_COMPRESS_START==magic_start or MAGIC_COMPRESS_START1==magic_start:
    crypt_key_len = 4
elif MAGIC_COMPRESS_START2==magic_start or MAGIC_NO_COMPRESS_START1==magic_start or MAGIC_NO_COMPRESS_NO_CRYPT_START==magic_start or MAGIC_COMPRESS_NO_CRYPT_START==magic_start \
        or MAGIC_SYNC_ZSTD_START == magic_start or MAGIC_SYNC_NO_CRYPT_ZSTD_START == magic_start or MAGIC_ASYNC_ZSTD_START == magic_start or MAGIC_ASYNC_NO_CRYPT_ZSTD_START == magic_start:
    crypt_key_len = 64
else:
    return (False, '_buffer[%d]:%d != MAGIC_NUM_START'%(_offset, _buffer[_offset]))

headerLen = 1 + 2 + 1 + 1 + 4 + crypt_key_len

if _offset + headerLen + 1 + 1 > len(_buffer): return (False, 'offset:%d > len(buffer):%d'%(_offset, len(_buffer)))
length = struct.unpack_from("I", buffer(_buffer, _offset+headerLen-4-crypt_key_len, 4))[0]
if _offset + headerLen + length + 1 > len(_buffer): return (False, 'log length:%d, end pos %d > len(buffer):%d'%(length, _offset + headerLen + length + 1, len(_buffer)))
if MAGIC_END!=_buffer[_offset + headerLen + length]: return (False, 'log length:%d, buffer[%d]:%d != MAGIC_END'%(length, _offset + headerLen + length, _buffer[_offset + headerLen + length]))


if (1>=count): return (True, '')
else: return IsGoodLogBuffer(_buffer, _offset+headerLen+length+1, count-1)

def GetLogStartPos(_buffer, _count):
offset = 0
while True:
if offset >= len(_buffer): break

    if MAGIC_NO_COMPRESS_START==_buffer[offset] or MAGIC_NO_COMPRESS_START1==_buffer[offset] or MAGIC_COMPRESS_START==_buffer[offset] or MAGIC_COMPRESS_START1==_buffer[offset] or MAGIC_COMPRESS_START2==_buffer[offset] or MAGIC_COMPRESS_NO_CRYPT_START==_buffer[offset] or MAGIC_NO_COMPRESS_NO_CRYPT_START==_buffer[offset]\
        or MAGIC_SYNC_ZSTD_START == _buffer[offset] or MAGIC_SYNC_NO_CRYPT_ZSTD_START == _buffer[offset] or MAGIC_ASYNC_ZSTD_START == _buffer[offset] or MAGIC_ASYNC_NO_CRYPT_ZSTD_START == _buffer[offset]:
        if IsGoodLogBuffer(_buffer, offset, _count)[0]: return offset
    offset+=1
    
return -1

def DecodeBuffer(_buffer, _offset, _outbuffer):

if _offset >= len(_buffer): return -1
# if _offset + 1 + 4 + 1 + 1 > len(_buffer): return -1
ret = IsGoodLogBuffer(_buffer, _offset, 1)
if not ret[0]:
    fixpos = GetLogStartPos(_buffer[_offset:], 1)
    if -1==fixpos: 
        return -1
    else:
        _outbuffer.extend("[F]decode_log_file.py decode error len=%d, result:%s \n"%(fixpos, ret[1]))
        _offset += fixpos 

magic_start = _buffer[_offset]
if MAGIC_NO_COMPRESS_START==magic_start or MAGIC_COMPRESS_START==magic_start or MAGIC_COMPRESS_START1==magic_start:
    crypt_key_len = 4
elif MAGIC_COMPRESS_START2==magic_start or MAGIC_NO_COMPRESS_START1==magic_start or MAGIC_NO_COMPRESS_NO_CRYPT_START==magic_start or MAGIC_COMPRESS_NO_CRYPT_START==magic_start\
    or MAGIC_SYNC_ZSTD_START == magic_start or MAGIC_SYNC_NO_CRYPT_ZSTD_START == magic_start or MAGIC_ASYNC_ZSTD_START == magic_start or MAGIC_ASYNC_NO_CRYPT_ZSTD_START == magic_start:
    crypt_key_len = 64
else:
    _outbuffer.extend('in DecodeBuffer _buffer[%d]:%d != MAGIC_NUM_START'%(_offset, magic_start))
    return -1

headerLen = 1 + 2 + 1 + 1 + 4 + crypt_key_len
length = struct.unpack_from("I", buffer(_buffer, _offset+headerLen-4-crypt_key_len, 4))[0]
tmpbuffer = bytearray(length)

seq=struct.unpack_from("H", buffer(_buffer, _offset+headerLen-4-crypt_key_len-2-2, 2))[0]
begin_hour=struct.unpack_from("c", buffer(_buffer, _offset+headerLen-4-crypt_key_len-1-1, 1))[0]
end_hour=struct.unpack_from("c", buffer(_buffer, _offset+headerLen-4-crypt_key_len-1, 1))[0]

global lastseq
if seq != 0 and seq != 1 and lastseq != 0 and seq != (lastseq+1):
    _outbuffer.extend("[F]decode_log_file.py log seq:%d-%d is missing\n" %(lastseq+1, seq-1))

if seq != 0:
    lastseq = seq

tmpbuffer[:] = _buffer[_offset+headerLen:_offset+headerLen+length]

try:


    if MAGIC_NO_COMPRESS_START1==_buffer[_offset] or MAGIC_SYNC_ZSTD_START==_buffer[_offset]:
        pass
    
    elif MAGIC_COMPRESS_START2==_buffer[_offset] or MAGIC_ASYNC_ZSTD_START==_buffer[_offset]:
        svr = pyelliptic.ECC(curve='secp256k1')
        client = pyelliptic.ECC(curve='secp256k1')
        client.pubkey_x = str(buffer(_buffer, _offset+headerLen-crypt_key_len, crypt_key_len/2))
        client.pubkey_y = str(buffer(_buffer, _offset+headerLen-crypt_key_len/2, crypt_key_len/2))

        svr.privkey = binascii.unhexlify(PRIV_KEY)
        tea_key = svr.get_ecdh_key(client.get_pubkey())

        tmpbuffer = tea_decrypt(tmpbuffer, tea_key)
        if MAGIC_COMPRESS_START2==_buffer[_offset]:
            decompressor = zlib.decompressobj(-zlib.MAX_WBITS)
            tmpbuffer = decompressor.decompress(str(tmpbuffer))
        else:
            decompressor = zstd.ZstdDecompressor()
            tmpbuffer = next(decompressor.read_from(ZstdDecompressReader(str(tmpbuffer)), 100000, 1000000))
    elif MAGIC_ASYNC_NO_CRYPT_ZSTD_START==_buffer[_offset]:
        decompressor = zstd.ZstdDecompressor()
        tmpbuffer = next(decompressor.read_from(ZstdDecompressReader(str(tmpbuffer)), 100000, 1000000))
    elif MAGIC_COMPRESS_START==_buffer[_offset] or MAGIC_COMPRESS_NO_CRYPT_START==_buffer[_offset]:
        decompressor = zlib.decompressobj(-zlib.MAX_WBITS)
        tmpbuffer = decompressor.decompress(str(tmpbuffer))
    elif MAGIC_COMPRESS_START1==_buffer[_offset]:
        decompress_data = bytearray()
        while len(tmpbuffer) > 0:
            single_log_len = struct.unpack_from("H", buffer(tmpbuffer, 0, 2))[0]
            decompress_data.extend(tmpbuffer[2:single_log_len+2])
            tmpbuffer[:] = tmpbuffer[single_log_len+2:len(tmpbuffer)]

        decompressor = zlib.decompressobj(-zlib.MAX_WBITS)
        tmpbuffer = decompressor.decompress(str(decompress_data))

    else:
        pass

        # _outbuffer.extend('seq:%d, hour:%d-%d len:%d decompress:%d\n' %(seq, ord(begin_hour), ord(end_hour), length, len(tmpbuffer)))
except Exception,e:
    traceback.print_exc()  
    _outbuffer.extend("[F]decode_log_file.py decompress err, " + str(e) + "\n")
    return _offset+headerLen+length+1

_outbuffer.extend(tmpbuffer)

return _offset+headerLen+length+1

def ParseFile(_file, _outfile):
fp = open(_file, "rb")
_buffer = bytearray(os.path.getsize(_file))
fp.readinto(_buffer)
fp.close()
startpos = GetLogStartPos(_buffer, 2)
if -1==startpos:
return

outbuffer = bytearray()

while True:
    startpos = DecodeBuffer(_buffer, startpos, outbuffer)
    if -1==startpos: break;

if 0==len(outbuffer): return

fpout = open(_outfile, "wb")
fpout.write(outbuffer)
fpout.close()

def main(args):
global lastseq

if 1==len(args):
    if os.path.isdir(args[0]):
        filelist = glob.glob(args[0] + "/*.xlog")
        for filepath in filelist:
            lastseq = 0
            ParseFile(filepath, filepath+".log")
    else: ParseFile(args[0], args[0]+".log")    
elif 2==len(args):
    ParseFile(args[0], args[1])    
else: 
    filelist = glob.glob("*.xlog")
    for filepath in filelist:
        lastseq = 0
        ParseFile(filepath, filepath+".log")

if name == "main":
main(sys.argv[1:])

Mars Xlog windows环境使用实践
准备工作：python2.7环境，通过git克隆mars项目注意： marxlog 脚本decode_mars_...
聊聊微信 Xlog
同步地址本文介绍 MARS xlog 使用以及使用过程中踩过的坑 xlog 是什么 xlog 是微信开源框架 M...
XLog 详解及源码分析
一、前言这里的 XLog 不是微信 Mars 里面的 xLog，而是elvishew的xLog。感兴趣的同学可以...
微信Mars——Xlog使用
开源地址：https://github.com/Tencent/mars Log生成完毕后，会在指定的路径下生成相...
平安好房iOS开发团队技术周报（第三十四期）
本期导读：本期周报主要包括苹果 2017 新年大促消息、微信 Mars 之 xlog 使用、APP 引导页的设计、...
Mars-日志模块xlog for React-Native (
本文主要介绍Mars-xlog的使用过程（iOS），与react-native相关部分，则参考了react-nat...
腾讯Mars-Xlog日志解析报错- No module nam
在使用腾讯的Mars的Xlog查看本地log文件的时候，解析log文件，在控制台报出No module named...
iOS 接入xlog
接入xlog 参考链接:iOS接入指南[https://github.com/Tencent/mars/wiki/...
微信Mars——xlog使用全解析
微信Mars——xlog使用全解析很多人问我微信的Mars到底有什么用，今天就告诉你其中一个最简单的！如约而至...
需要学习文章
微信高性能线上日志系统xlog剖析【Dev Club 分享】微信mars 的高性能日志模块 xlog 微信跨平台...