V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python Sites
PyPI - Python Package Index
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
fjhh
V2EX  ›  Python

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

  •  
  •   fjhh · 2018-03-31 22:51:38 +08:00 · 1659 次点击
    这是一个创建于 2189 天前的主题,其中的信息可能已经有所发展或是发生改变。
    想写个小脚本,调用 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)
    目前尚无回复
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   我们的愿景   ·   实用小工具   ·   1475 人在线   最高记录 6543   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 27ms · UTC 17:21 · PVG 01:21 · LAX 10:21 · JFK 13:21
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.