Python代理框架mitmproxy、wyproxy使用难题，如何调用mitmproxy实现代理并输出所有请求URL及返回数据至文件

想写个小脚本，调用 mimtproxy 开启代理，自动记录所有请求 URL 及返回数据至文件中。搜索到 wyproxy 实现了类似的功能，但功能繁多，想修改为自用小程序，分析学习过程中，对于 wyproxy 的程序逻辑无法理解。特来求问，感谢。

执行 wyproxy，程序先运行 run()函数，接下来到 wyDaemon.run()，再 start_server()，再 WYProxy.run()
而入库是 WYProxy 类中的 response 函数，并没有看到调用，可数据被存储进库里。
求问 wyproxy 的入库流程是？可有更简要的脚本调用 mimtproxy 记录所有请求 URL 及返回数据至文件中？无限感谢。
https://github.com/ring04h/wyproxy/blob/master/wyproxy.py

#!/usr/bin/env python
# encoding: utf-8

import sys
import argparse
import logging

from utils.daemon import Daemon
from mitmproxy import flow, proxy, controller, options
from mitmproxy.proxy.server import ProxyServer
from utils.parser import ResponseParser, save_cnf, read_cnf
from utils.handle import wyproxy_request_handle, wyproxy_response_handle
from utils.mysql import MysqlInterface

logging.basicConfig(
level=logging.INFO, # filename=’/tmp/wyproxy.log’,
format=’%(asctime)s [%(levelname)s] %(message)s’,
)

class WYProxy(flow.FlowMaster):

def init(self, opts, server, state, unsave_data):
super(WYProxy, self).init(opts, server, state)
self.unsave_data = unsave_data

def run(self):
try:
logging.info(“wyproxy started successfully…”)
flow.FlowMaster.run(self)
except KeyboardInterrupt:
self.shutdown()
logging.info(“Ctrl C - stopping wyproxy server”)

@controller.handler
def request(self, f):
wyproxy_request_handle(f)

@controller.handler
def response(self, f):
wyproxy_response_handle(f)
if not self.unsave_data:
try:
parser = ResponseParser(f)
mysqldb_io = MysqlInterface()

mysqldb_io.insert_result(parser.parser_data())
except Exception as e:
logging.error(str(e))


# memory overfull bug
# print(len(self.state.flows))
# print(self.state.flow_count())
# self.state.clear()

def start_server(proxy_port, proxy_mode, unsave_data):
port = int(proxy_port) if proxy_port else 8080
mode = proxy_mode if proxy_mode else ‘regular’

if proxy_mode == ‘http’:
mode = ‘regular’

opts = options.Options(
listen_port=port,
mode=mode,
cadir="./ssl/",
)

config = proxy.ProxyConfig(opts)

state = flow.State()
server = ProxyServer(config)
m = WYProxy(opts, server, state, unsave_data)
m.run()

class wyDaemon(Daemon):

def init(self, pidfile, proxy_port=8080, proxy_mode=‘regular’, unsave_data=False):
super(wyDaemon, self).init(pidfile)
self.proxy_port = proxy_port
self.proxy_mode = proxy_mode
self.unsave_data = unsave_data

def run(self):
logging.info(“wyproxy is starting…”)
logging.info(“Listening: 0.0.0.0:{} {}”.format(
self.proxy_port, self.proxy_mode))
start_server(self.proxy_port, self.proxy_mode, self.unsave_data)

def run(args):

if args.restart:
args.port = read_cnf().get(‘port’)
args.mode = read_cnf().get(‘mode’)
args.unsave = read_cnf().get(‘unsave’)

if not args.pidfile:
args.pidfile = ‘/tmp/wyproxy.pid’


wyproxy = wyDaemon(
pidfile = args.pidfile,
proxy_port = args.port,
proxy_mode = args.mode,
unsave_data = args.unsave)

if args.daemon:
save_cnf(args)
wyproxy.start()
elif args.stop:
wyproxy.stop()
elif args.restart:
wyproxy.restart()
else:
wyproxy.run()

if name == ‘main’:

parser = argparse.ArgumentParser(description=“wyproxy v 1.0 ( Proxying And Recording HTTP/HTTPs and Socks5)”)
parser.add_argument("-d","–daemon",action=“store_true”,
help=“start wyproxy with daemond”)
parser.add_argument("-stop","–stop",action=“store_true”,required=False,
help=“stop wyproxy daemond”)
parser.add_argument("-restart","–restart",action=“store_true”,required=False,
help=“restart wyproxy daemond”)
parser.add_argument("-pid","–pidfile",metavar="",
help=“wyproxy daemond pidfile name”)
parser.add_argument("-p","–port",metavar="",default=“8080”,
help=“wyproxy bind port”)
parser.add_argument("-m","–mode",metavar="",choices=[‘http’,‘socks5’,‘transparent’],default=“http”,
help=“wyproxy mode (HTTP/HTTPS, Socks5, Transparent)”)
parser.add_argument("-us","–unsave",action=“store_true”,required=False,
help=“Do not save records to MySQL server”)
args = parser.parse_args()

try:
run(args)
except KeyboardInterrupt:
logging.info(“Ctrl C - Stopping Client”)
sys.exit(1)
Python代理框架mitmproxy、wyproxy使用难题，如何调用mitmproxy实现代理并输出所有请求URL及返回数据至文件