程式碼改造實錄--合併可以替代的資料訪問
阿新 • • 發佈:2020-08-13
用python3對json內容逐層進行解析,拿中國天氣網的介面返回資料測試,
程式碼如下:
# -*- coding: utf-8 -*- importoperator as op fromcollections importdefaultdict classJson(object): def__init__(self, json: str): sth =eval(json) load =lambdasth: sth ifop.eq(type(sth).__name__, dict.__name__) elseNone self.json_dict =load(sth) self.ret_j =defaultdict(dict) self.analyze(self.json_dict) defanalyze(self, j_dict: dict, lvl=0) -> None: lvl +=1 fork inj_dict: v =j_dict[k] v_type =type(v) try: self.ret_j[lvl][str(j_dict)].append(f"{k}:{v}") except: self.ret_j[lvl][str(j_dict)] =[] self.ret_j[lvl][str(j_dict)].append(f"{k}:{v}") ifop.eq(v_type.__name__, dict.__name__): self.analyze(v, lvl) elifop.eq(v_type.__name__, list.__name__): foreach inv: ifop.eq(type(each).__name__, dict.__name__): self.analyze(each, lvl) defget_analysis(self) -> None: print(f"這個json攏共分{len(self.ret_j)}層") print("------") forlvl inself.ret_j: print(f"第{lvl}層解析") forroot inself.ret_j[lvl]: print(f"解析內容:{root}") foreach inself.ret_j[lvl][root]: print(each) print("------") if__name__ =='__main__': try: importrequests except: exit(0) url ="http://forecast.weather.com.cn/napi/h5map/city/101/jQuery1533133004035?callback=jQuery1533133004035" r =requests.get(url) d_r =r.content.decode() json_4_test =d_r[d_r.index("(") +1:d_r.index(")")] Json(json_4_test).get_analysis() 其中json_4_test是待解析的json字串。
設計思路:
補充知識:python之logging模組:將不同的日誌寫入到不同的檔案
如下所示:
importlogging.config fromlogging importLogRecord # 通常用於Linux系統下,使控制檯輸出的日誌帶顏色 classColorFormatter(logging.Formatter): log_colors ={ 'CRITICAL': '\033[0;31m', 'ERROR': '\033[0;33m', 'WARNING': '\033[0;35m', 'INFO': '\033[0;32m', 'DEBUG': '\033[0;00m', } defformat(self, record: LogRecord) -> str: s =super().format(record) level_name =record.levelname iflevel_name inself.log_colors: returnself.log_colors[level_name] +s +'\033[0m' returns classMyFilter400(logging.Filter): deffilter(self, record: LogRecord): ifrecord.msg.startswith("4"): returnTrue returnFalse classMyFilter300(logging.Filter): deffilter(self, record: LogRecord): ifrecord.msg.startswith("3"): returnTrue returnFalse LOG_LEVEL =logging.INFO LOGGER ={ 'version': 1, 'disable_existing_loggers': True, 'formatters': { 'color': { 'class': '__main__.ColorFormatter', # 如果你的模組不是寫在啟動程式中,請將__main__更換成你模組的路徑,下同 'format': '%(asctime)s [%(name)s] %(levelname)s: %(message)s' }, 'default': { 'class': 'logging.Formatter', 'format': '%(message)s' } }, 'filters': { 'filter_400': { '()': '__main__.MyFilter400' }, 'filter_300': { '()': '__main__.MyFilter300' } }, 'handlers': { 'console': { 'level': LOG_LEVEL, 'class': 'logging.StreamHandler', 'formatter': 'color', }, 'file1': { 'level': LOG_LEVEL, 'class': 'logging.FileHandler', 'mode': 'w', 'formatter': 'default', 'filename': '400_log.txt', 'encoding': 'utf-8', 'filters': ['filter_400'] }, 'file2': { 'level': LOG_LEVEL, 'class': 'logging.FileHandler', 'mode': 'w', 'formatter': 'default', 'filename': '300_log.txt', 'encoding': 'utf-8', 'filters': ['filter_300'] }, }, 'loggers': { '__main__': { 'handlers': ['file1', 'file2', 'console'], 'level': LOG_LEVEL, }, } } logging.config.dictConfig(LOGGER) logger =logging.getLogger(__name__) logger.debug('200,this is a logger debug message') logger.info('302,this is a logger info message') logger.warning('301,this is a logger warning message') logger.error('404,this is a logger error message') logger.critical('500,this is a logger critical message') print("%s"%__name__)
執行效果圖:
控制檯:
檔案:
3開頭的寫入到300_log.txt
4開頭的寫入到400_log.txt
特別注意,使用過濾器的一個問題
classMyFilter400And500(logging.Filter): deffilter(self, record: LogRecord): ifrecord.msg.startswith("4") orrecord.msg.startswith("5"): returnTrue returnFalse # record.msg = "404, %s, %s" logger.info(f"{status_code}, %s, %s", website, link) # record.msg = "%s, %s, %s",這就導致過濾器返回False logger.info("%s, %s, %s", status_code, website, link)
因此,如果發現訊息沒有寫入檔案,可能是訊息格式的問題。
目前,官方推薦字串格式化的方式就是第一種方式,%s和.format()的方式都不如這個好。
以上這篇Python3自定義json逐層解析器程式碼就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支援。