av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

Python 實(shí)時(shí)獲取任務(wù)請(qǐng)求對(duì)應(yīng)的Nginx日志的方法

瀏覽:134日期:2022-06-15 10:13:01
需求描述

項(xiàng)目需求測試過程中,需要向Nginx服務(wù)器發(fā)送一些用例請(qǐng)求,然后查看對(duì)應(yīng)的Nginx日志,判斷是否存在特征內(nèi)容,來判斷任務(wù)是否執(zhí)行成功。為了提升效率,需要將這一過程實(shí)現(xiàn)自動(dòng)化。

實(shí)踐環(huán)境

Python 3.6.5

代碼設(shè)計(jì)與實(shí)現(xiàn)

#!/usr/bin/env python# -*- coding:utf-8 -*-’’’@CreateTime: 2021/06/26 9:05@Author : shouke’’’import timeimport threadingimport subprocessfrom collections import dequedef collect_nginx_log(): global nginx_log_queue global is_tasks_compete global task_status args = ’tail -0f /usr/local/openresty/nginx/logs/access.log’ while task_status != ’req_log_got’:with subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True, universal_newlines = True) as proc: log_for_req = ’’ outs, errs = ’’, ’’ try:outs, errs = proc.communicate(timeout=2) except subprocess.TimeoutExpired:print(’獲取nginx日志超時(shí),正在重試’)proc.kill()try: outs, errs = proc.communicate(timeout=5)except subprocess.TimeoutExpired: print(’獲取nginx日志超時(shí),再次超時(shí),停止重試’) break finally:for line in outs.split(’n’): flag = ’'client_ip':'10.118.0.77'’ # 特征 if flag in line: # 查找包含特征內(nèi)容的日志log_for_req += lineif task_status == ’req_finished’: nginx_log_queue.append(log_for_req) task_status = ’req_log_got’def run_tasks(task_list): ’’’ 運(yùn)行任務(wù) :param task_list 任務(wù)列表 ’’’ global nginx_log_queue global is_tasks_compete global task_status for task in task_list:thread = threading.Thread(target=collect_nginx_log, name='collect_nginx_log')thread.start()time.sleep(1) # 執(zhí)行任務(wù)前,讓收集日志線程先做好準(zhǔn)備print(’正在執(zhí)行任務(wù):%s’ % task.get(’name’))# 執(zhí)行Nginx任務(wù)請(qǐng)求# ...task_status = ’req_finished’time_to_wait = 0.1while task_status != ’req_log_got’: # 請(qǐng)求觸發(fā)的nginx日志收集未完成 time.sleep(time_to_wait) time_to_wait += 0.01else:# 獲取到用例請(qǐng)求觸發(fā)的nginx日志 if nginx_log_queue:nginx_log = nginx_log_queue.popleft()task_status = ’req_ready’# 解析日志# do something here# ... else:print(’存儲(chǔ)請(qǐng)求日志的隊(duì)列為空’)# do something here# ...if __name__ == ’__main__’: nginx_log_queue = deque() is_tasks_compete = False # 所有任務(wù)是否執(zhí)行完成 task_status = ’req_ready’ # req_ready,req_finished,req_log_got # 存放執(zhí)行次任務(wù)任務(wù)的一些狀態(tài) print(’###########################任務(wù)開始###########################’) tast_list = [{’name’:’test_task’, ’other’:’...’}] run_tasks(tast_list) is_tasks_compete = True current_active_thread_num = len(threading.enumerate()) while current_active_thread_num != 1:time.sleep(2)current_active_thread_num = len(threading.enumerate()) print(’###########################任務(wù)完成###########################’)

注意:

1、上述代碼為啥不一步到位,直接 tail -0f /usr/local/openresty/nginx/logs/access.log | grep '特征內(nèi)容'呢?這是因?yàn)檫@樣做無法獲取到Nginx的日志

2、實(shí)踐時(shí)發(fā)現(xiàn),第一次執(zhí)行proc.communicate(timeout=2)獲取日志時(shí),總是無法獲取,會(huì)超時(shí),需要二次獲取,并且timeout設(shè)置太小時(shí)(實(shí)踐時(shí)嘗試過設(shè)置為1秒),也會(huì)導(dǎo)致第二次執(zhí)行時(shí)無法獲取Nginx日志。

到此這篇關(guān)于Python 實(shí)時(shí)獲取任務(wù)請(qǐng)求對(duì)應(yīng)的Nginx日志的文章就介紹到這了,更多相關(guān)Python獲取Nginx日志內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 日韩欧美在线观看视频 | 欧美中国少妇xxx性高请视频 | 久草视频在线播放 | 色婷婷av一区二区三区软件 | 中文字幕在线观看精品 | 韩日精品视频 | 久久黄网 | 欧美激情一区二区三级高清视频 | 亚洲一二三区av | 国产福利在线 | 国产精品视频久久 | 久久极品 | 成人免费观看男女羞羞视频 | 天天摸天天看 | 久久国产欧美日韩精品 | 婷婷在线网站 | 精品9999| 国产免费自拍 | 中文字幕一区二区三区四区五区 | 福利电影在线 | 日日夜夜精品视频 | 国产亚洲二区 | 香蕉视频1024 | 中国一级毛片免费 | 国产线视频精品免费观看视频 | 久久精品99| 91亚洲精 | 日韩一区二区三区av | 亚洲欧洲视频 | 99re在线视频| 一区二区三区四区在线视频 | www.青娱乐| 欧美日韩在线视频观看 | 欧美不卡一区二区 | av片毛片 | 日韩无 | 成人在线视频一区 | 亚洲狠狠爱 | 久久国产精品免费一区二区三区 | 久久久蜜桃一区二区人 | 国产成人小视频 |