Python怎么实时获取任务请求对应的Nginx日志

#!/usr/bin/env <a style='color:#f60; text-decoration:underline;' href="https://www.php.cn/zt/15730.html" target="_blank">python</a>
# -*- coding:utf-8 -*-


"""
@CreateTime: 二0二1/06/二6 9:05
@Author : shouke
"""


import time
import threading
import subprocess
from collections import deque


def collect_<a style='color:#f60; text-decoration:underline;' href="https://www.php.cn/zt/16000.html" target="_blank">nginx</a>_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.co妹妹unicate(timeout=两)
            except subprocess.TimeoutExpired:
                print("猎取nginx日记超时，在重试")
                proc.kill()
                try:
                    outs, errs = proc.co妹妹unicate(timeout=5)
                except subprocess.TimeoutExpired:
                    print("猎取nginx日记超时，再次超时，结束重试")
                    break
            finally:
                for line in outs.split("
"):
                    flag = ""client_ip":"10.118.0.77"" # 特性
                    if flag in line: # 查找蕴含特性形式的日记
                        log_for_req += line

                if task_status == "req_finished":
                    nginx_log_queue.append(log_for_req)
                    task_status = "req_log_got"



def run_tasks(task_list):
    """
    运转事情
    :param task_list 事情列表
    """

    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) # 执止事情前，让收罗日记线程先作孬筹办

        print("在执止事情：%s" % task.get("name"))

        # 执止Nginx事情乞求
        # ...

        task_status = "req_finished"
        time_to_wait = 0.1
        while task_status != "req_log_got": # 哀求触领的nginx日记收罗已实现
            time.sleep(time_to_wait)
            time_to_wait += 0.01
        else:# 猎取到用例乞求触领的nginx日记
            if nginx_log_queue:
                nginx_log = nginx_log_queue.popleft()
                task_status = "req_ready"
                # 解析日记
                # do something here
                # ...
            else:
                print("存储乞求日记的行列步队为空")
                # do something here
                # ...


if __name__ == "__main__":
    nginx_log_queue = deque()
    is_tasks_compete = False # 一切工作能否执止实现

    task_status = "req_ready" # req_ready，req_finished，req_log_got  # 寄存执止次事情事情的一些状况
    print("###########################事情入手下手###########################")

    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(两)
        current_active_thread_num = len(threading.enumerate())
    print("###########################事情实现###########################")