diff --git a/common/templates/config.html b/common/templates/config.html
index e488ccc4c5..207f4e24a8 100644
--- a/common/templates/config.html
+++ b/common/templates/config.html
@@ -218,7 +218,7 @@ <h5 style="color: darkgrey"><b>SQL查询</b></h5>
                                             <input id="disable_star"
                                                    key="disable_star"
                                                    value="{{ config.disable_star }}" type="checkbox">
-                                            禁止在查询时使用 * 
+                                            禁止在查询时使用 *
                                         </label>
                                     </div>
                                 </div>
@@ -287,6 +287,21 @@ <h5 style="color: darkgrey"><b>SQL优化</b></h5>
                         <h4 style="color: darkgrey;display: inline"><b>通知配置</b></h4>&nbsp;&nbsp;&nbsp;
                         <button id='check_email' class='btn-sm btn-info'>测试EMAIL连接</button>
                         <hr/>
+                        <div class="form-group">
+                            <label for="archery_base_url"
+                                   class="col-sm-4 control-label">ARCHERY_BASE_URL</label>
+                            <div class="col-sm-8">
+                                <div class="switch switch-small">
+                                    <label>
+                                        <input type="text" class="form-control"
+                                               id="archery_base_url"
+                                               key="archery_base_url"
+                                               value="{{ config.archery_base_url }}"
+                                               placeholder="http://archery.com">系统首页地址, 用于钉钉和邮件发送链接使用
+                                    </label>
+                                </div>
+                            </div>
+                        </div>
                         <div class="form-horizontal">
                             <div class="form-group">
                                 <label for="mail"
@@ -398,6 +413,17 @@ <h4 style="color: darkgrey"><b>其他配置</b></h4>
                                            placeholder="schemasync调用路径">
                                 </div>
                             </div>
+                            <div class="form-group">
+                                <label for="lock_time_threshold"
+                                       class="col-sm-4 control-label">BINLOG2SQL</label>
+                                <div class="col-sm-5">
+                                    <input type="text" class="form-control"
+                                           id="binlog2sql"
+                                           key="binlog2sql"
+                                           value="{{ config.binlog2sql }}"
+                                           placeholder="binlog2sql调用路径，类似/opt/binlog2sql.py">
+                                </div>
+                            </div>
                             <div class="form-group">
                                 <label for="default_auth_group"
                                        class="col-sm-4 control-label">DEFAULT_AUTH_GROUP</label>
@@ -448,27 +474,13 @@ <h4 style="color: darkgrey"><b>其他配置</b></h4>
                                 <div class="col-sm-8">
                                     <div class="switch switch-small">
                                         <label>
-                                            <input id="sign_up_enabled" key="sign_up_enabled" value="{{ config.sign_up_enabled }}"
+                                            <input id="sign_up_enabled" key="sign_up_enabled"
+                                                   value="{{ config.sign_up_enabled }}"
                                                    type="checkbox"> 是否开启注册功能
                                         </label>
                                     </div>
                                 </div>
                             </div>
-                            <div class="form-group">
-                                <label for="archery_base_url"
-                                       class="col-sm-4 control-label">ARCHERY_BASE_URL</label>
-                                <div class="col-sm-8">
-                                    <div class="switch switch-small">
-                                        <label>
-                                            <input type="text" class="form-control"
-                                                id="archery_base_url"
-                                                key="archery_base_url"
-                                                value="{{ config.archery_base_url }}"
-                                                placeholder="http://archery.com">系统首页地址, 用于钉钉和邮件发送链接使用
-                                        </label>
-                                    </div>
-                                </div>
-                            </div>
                         </div>
                         <div class="form-group">
                             <div class="col-sm-offset-4 col-sm-10">
@@ -526,13 +538,11 @@ <h5 class="control-label text-bold">当前审批流程：<b id="workflow_auditor
                 $('input[type="checkbox"]').each(function (i) {
                     if ($(this).val() === 'true') {
                         $(this).bootstrapSwitch('state', true);
-                    }
-                    else {
+                    } else {
                         $(this).bootstrapSwitch('state', false);
                     }
                 });
-            }
-            else if ($("#config").val() === '1') {
+            } else if ($("#config").val() === '1') {
                 $("#div-system-config").hide();
                 $("#div-workflow").show();
                 $("#div-workflow-config").show();
@@ -546,18 +556,15 @@ <h5 class="control-label text-bold">当前审批流程：<b id="workflow_auditor
                 $(this).val(true);
                 if ($(this).attr("id") === 'mail') {
                     $("#div-mail-config").show();
-                }
-                else if ($(this).attr("id") === 'auto_review') {
+                } else if ($(this).attr("id") === 'auto_review') {
                     $("#div-auto-review-config").show();
                 }
-            }
-            else {
+            } else {
                 $(this).val(false);
                 if ($(this).attr("id") === 'mail') {
                     $("#mail_ssl").val(false);
                     $("#div-mail-config").hide();
-                }
-                else if ($(this).attr("id") === 'auto_review') {
+                } else if ($(this).attr("id") === 'auto_review') {
                     $("#div-auto-review-config").hide();
                 }
             }
@@ -611,8 +618,7 @@ <h5 class="control-label text-bold">当前审批流程：<b id="workflow_auditor
             var auditors = $("#workflow_auditors_text").val();
             if (auditors) {
                 $("#workflow_auditors_text").val(auditors + '->' + auth_group);
-            }
-            else {
+            } else {
                 $("#workflow_auditors_text").val(auth_group)
             }
             $('#group_auditors').selectpicker('render');
@@ -687,8 +693,7 @@ <h5 class="control-label text-bold">当前审批流程：<b id="workflow_auditor
                         alert(errorThrown);
                     }
                 });
-            }
-            else {
+            } else {
                 alert('请选择组、工单类型和审批流程！')
             }
 
@@ -764,8 +769,7 @@ <h5 class="control-label text-bold">当前审批流程：<b id="workflow_auditor
         $(document).ready(function () {
             if (sessionStorage.getItem('config_type')) {
                 $("#config").val(sessionStorage.getItem('config_type')).trigger("change")
-            }
-            else if ($("#config").val()) {
+            } else if ($("#config").val()) {
                 $("#config").trigger("change")
             }
         })
diff --git a/sql/binlog2sql.py b/sql/binlog.py
similarity index 50%
rename from sql/binlog2sql.py
rename to sql/binlog.py
index 2379c0ad7a..e00f2f2911 100644
--- a/sql/binlog2sql.py
+++ b/sql/binlog.py
@@ -9,10 +9,12 @@
 from django.conf import settings
 from django.contrib.auth.decorators import permission_required
 from django.http import HttpResponse
+from django_q.tasks import async_task
 
 from common.utils.extend_json_encoder import ExtendJSONEncoder
 from sql.engines import get_engine
-from sql.utils.binlog2sql.binlog2sql import Binlog2sql
+
+from sql.plugins.binglog2sql import Binlog2Sql
 from .models import Instance
 
 logger = logging.getLogger('default')
@@ -48,11 +50,12 @@ def binlog_list(request):
 @permission_required('sql.menu_binlog2sql', raise_exception=True)
 def binlog2sql(request):
     instance_name = request.POST.get('instance_name')
+    save_sql = True if request.POST.get('save_sql') == 'true' else False
     instance = Instance.objects.get(instance_name=instance_name)
-    conn_setting = {'host': instance.host, 'port': int(instance.port), 'user': instance.user,
-                    'passwd': instance.raw_password, 'charset': 'utf8'}
     no_pk = True if request.POST.get('no_pk') == 'true' else False
     flashback = True if request.POST.get('flashback') == 'true' else False
+    back_interval = 0 if request.POST.get('back_interval') == '' else int(request.POST.get('back_interval'))
+    num = 500 if request.POST.get('num') == '' else int(request.POST.get('num'))
     start_file = request.POST.get('start_file')
     start_pos = request.POST.get('start_pos') if request.POST.get('start_pos') == '' else int(
         request.POST.get('start_pos'))
@@ -68,50 +71,88 @@ def binlog2sql(request):
 
     # flashback=True获取DML回滚语句
     result = {'status': 0, 'msg': 'ok', 'data': ''}
+
+    # 提交给binlog2sql进行解析
+    binlog2sql = Binlog2Sql()
+    # 准备参数
+    args = {"conn_options": fr"-h{instance.host} -u{instance.user} -p'{instance.raw_password}' -P{instance.port} ",
+            "stop_never": False,
+            "no-primary-key": no_pk,
+            "flashback": flashback,
+            "back-interval": back_interval,
+            "start-file": start_file,
+            "start-position": start_pos,
+            "stop-file": end_file,
+            "stop-position": end_pos,
+            "start-datetime": start_time,
+            "stop-datetime": stop_time,
+            "databases": ' '.join(only_schemas),
+            "tables": ' '.join(only_tables),
+            "only-dml": only_dml,
+            "sql-type": ' '.join(sql_type),
+            "instance": instance
+            }
+
+    # 参数检查
+    args_check_result = binlog2sql.check_args(args)
+    if args_check_result['status'] == 1:
+        return HttpResponse(json.dumps(args_check_result), content_type='application/json')
+    # 参数转换
+    cmd_args = binlog2sql.generate_args2cmd(args, shell=True)
+    # 执行命令
     try:
-        binlog2sql = Binlog2sql(connection_settings=conn_setting, start_file=start_file, start_pos=start_pos,
-                                end_file=end_file, end_pos=end_pos, start_time=start_time,
-                                stop_time=stop_time, only_schemas=' '.join(only_schemas),
-                                only_tables=' '.join(only_tables),
-                                no_pk=no_pk, flashback=flashback, stop_never=False,
-                                back_interval=1.0, only_dml=only_dml, sql_type=sql_type)
-        timestamp = int(time.time())
-        path = os.path.join(settings.BASE_DIR, 'downloads/binlog2sql/')
-        if flashback:
-            filename = os.path.join(path, 'flashback_{}_{}_{}.sql'.format(conn_setting['host'],
-                                                                          conn_setting['port'],
-                                                                          timestamp))
-        else:
-            filename = os.path.join(path, '{}_{}_{}.sql'.format(conn_setting['host'],
-                                                                conn_setting['port'],
-                                                                timestamp))
-        # 获取sql语句，忽略wait_timeout的错误
-        try:
-            binlog2sql.process_binlog(filename)
-        except pymysql.err.OperationalError:
-            logger.error(traceback.format_exc())
-
-        # 读取前5000行
+        p = binlog2sql.execute_cmd(cmd_args, shell=True)
+        # 读取前500行
         rows = []
         n = 1
-        with open(filename) as f:
-            for row in f:
-                if n <= 5000:
-                    row_info = {}
-                    try:
-                        row_info['sql'] = row.split('; #')[0] + ";"
-                        row_info['binlog_info'] = row.split('; #')[1].rstrip('\"')
-                    except Exception:
-                        row_info['sql'] = row
-                        row_info['binlog_info'] = None
-                    rows.append(row_info)
-                    n = n + 1
+        for line in iter(p.stdout.readline, ''):
+            if n <= num:
+                n = n + 1
+                row_info = {}
+                try:
+                    row_info['sql'] = line.split('; #')[0] + ";"
+                    row_info['binlog_info'] = line.split('; #')[1].rstrip('\"')
+                except IndexError:
+                    row_info['sql'] = line
+                    row_info['binlog_info'] = None
+                rows.append(row_info)
+            else:
+                break
+        # 终止子进程
+        p.kill()
         result['data'] = rows
-    except Exception as e:
+    except RuntimeError as e:
         logger.error(traceback.format_exc())
         result['status'] = 1
         result['msg'] = str(e)
 
+    # 保存到文件
+    if save_sql:
+        async_task(binlog2sql_file, args=args)
+
     # 返回查询结果
     return HttpResponse(json.dumps(result, cls=ExtendJSONEncoder, bigint_as_string=True),
                         content_type='application/json')
+
+
+def binlog2sql_file(args):
+    """
+    :param cmd_args: 生成好的命令
+    :return:
+    """
+    binlog2sql = Binlog2Sql()
+    instance = args.get('instance')
+    timestamp = int(time.time())
+    path = os.path.join(settings.BASE_DIR, 'downloads/binlog2sql/')
+    if args.get('flashback'):
+        filename = os.path.join(path, f"flashback_{instance.host}_{instance.port}_{timestamp}.sql")
+    else:
+        filename = os.path.join(path, f"{instance.host}_{instance.port}_{timestamp}.sql")
+
+    # 参数转换
+    cmd_args = binlog2sql.generate_args2cmd(args, shell=True)
+    # 执行命令保存到文件
+    with open(filename, 'w') as f:
+        p = binlog2sql.execute_cmd(cmd_args, shell=True)
+        for c in iter(lambda: p.stdout.read(1), ''):
+            f.write(c)
diff --git a/sql/instance.py b/sql/instance.py
index e8bf376832..6b0cd8843f 100644
--- a/sql/instance.py
+++ b/sql/instance.py
@@ -122,7 +122,8 @@ def schemasync(request):
     cmd_args = schema_sync.generate_args2cmd(args, shell=True)
     # 执行命令
     try:
-        diff_stdout = schema_sync.execute_cmd(cmd_args, shell=True)
+        stdout, stderr = schema_sync.execute_cmd(cmd_args, shell=True).communicate()
+        diff_stdout = f'{stdout}{stderr}'
     except RuntimeError as e:
         diff_stdout = str(e)
 
diff --git a/sql/plugins/binglog2sql.py b/sql/plugins/binglog2sql.py
new file mode 100644
index 0000000000..197b19654c
--- /dev/null
+++ b/sql/plugins/binglog2sql.py
@@ -0,0 +1,61 @@
+# -*- coding: UTF-8 -*-
+""" 
+@author: hhyo 
+@license: Apache Licence 
+@file: binglog2sql.py 
+@time: 2019/03/23
+"""
+from common.config import SysConfig
+from sql.plugins.plugin import Plugin
+
+__author__ = 'hhyo'
+
+
+class Binlog2Sql(Plugin):
+
+    def __init__(self):
+        self.path = SysConfig().get('binlog2sql')
+        self.required_args = []
+        self.disable_args = []
+        super(Plugin, self).__init__()
+
+    def generate_args2cmd(self, args, shell):
+        """
+        转换请求参数为命令行
+        :param args:
+        :param shell:
+        :return:
+        """
+        conn_options = ['conn_options']
+        parse_mode_options = ['stop-never', 'no-primary-key', 'flashback', 'back-interval']
+        range_options = ['start-file', 'start-position', 'stop-file', 'stop-position', 'start-datetime',
+                         'stop-datetime']
+        filter_options = ['databases', 'tables', 'only-dml', 'sql-type']
+        if shell:
+            cmd_args = f'python {self.path}' if self.path else ''
+            for name, value in args.items():
+                if name in conn_options:
+                    cmd_args += f' {value}'
+                elif name in parse_mode_options and value:
+                    cmd_args += f' --{name}'
+                elif name in range_options and value:
+                    cmd_args += f' --{name}={value}'
+                elif name in filter_options and value:
+                    if name == 'only-dml':
+                        cmd_args += f' --{name}'
+                    else:
+                        cmd_args += f' --{name} {value}'
+        else:
+            cmd_args = [self.path]
+            for name, value in args.items():
+                if name in conn_options:
+                    cmd_args.append(f'{value}')
+                elif name in parse_mode_options:
+                    cmd_args.append(f'--{name}')
+                elif name in range_options:
+                    cmd_args.append(f'--{name}')
+                    cmd_args.append(f'{value}')
+                elif name in filter_options:
+                    cmd_args.append(f'--{name}')
+                    cmd_args.append(f'{value}')
+        return cmd_args
diff --git a/sql/plugins/plugin.py b/sql/plugins/plugin.py
index f615356a5e..2570ae3cc1 100644
--- a/sql/plugins/plugin.py
+++ b/sql/plugins/plugin.py
@@ -50,17 +50,16 @@ def generate_args2cmd(self, args, shell):
     @staticmethod
     def execute_cmd(cmd_args, shell):
         """
-        执行命令并且返回执行信息
+        执行命令并且返回process
         :return:
         """
         try:
             p = subprocess.Popen(cmd_args,
                                  shell=shell,
                                  stdout=subprocess.PIPE,
-                                 stderr=subprocess.STDOUT,
+                                 stderr=subprocess.PIPE,
                                  universal_newlines=True)
-            stdout, stderr = p.communicate()
-            return stdout
+            return p
         except Exception as e:
             logger.error("命令执行失败\n{}".format(traceback.format_exc()))
             raise RuntimeError('命令执行失败，失败原因:%s' % str(e))
diff --git a/sql/plugins/schemasync.py b/sql/plugins/schemasync.py
index 28fba3cf84..7daa2fb610 100644
--- a/sql/plugins/schemasync.py
+++ b/sql/plugins/schemasync.py
@@ -41,7 +41,7 @@ def generate_args2cmd(self, args, shell):
         else:
             cmd_args = [self.path]
             for name, value in args.items():
-                if name in k_options:
+                if name in k_options and value:
                     cmd_args.append(f'--{name}')
                 elif name in kv_options:
                     cmd_args.append(f'--{name}')
diff --git a/sql/plugins/tests.py b/sql/plugins/tests.py
index 8ffb863182..bc040af3ac 100644
--- a/sql/plugins/tests.py
+++ b/sql/plugins/tests.py
@@ -10,6 +10,7 @@
 from unittest.mock import patch, ANY
 from django.contrib.auth import get_user_model
 
+from sql.plugins.binglog2sql import Binlog2Sql
 from sql.plugins.schemasync import SchemaSync
 from sql.plugins.soar import Soar
 from sql.plugins.sqladvisor import SQLAdvisor
@@ -101,6 +102,10 @@ def test_check_args_required(self):
         self.assertDictEqual(args_check_result, {'status': 1, 'msg': 'query参数值不能为空', 'data': {}})
 
     def test_soar_generate_args2cmd(self):
+        """
+        测试SOAR参数转换
+        :return:
+        """
         args = {"online-dsn": '',
                 "test-dsn": '',
                 "allow-online-as-test": "false",
@@ -116,6 +121,10 @@ def test_soar_generate_args2cmd(self):
         self.assertIsInstance(cmd_args, str)
 
     def test_sql_advisor_generate_args2cmd(self):
+        """
+        测试sql_advisor参数转换
+        :return:
+        """
         args = {"h": 'mysql',
                 "P": 3306,
                 "u": 'root',
@@ -133,6 +142,10 @@ def test_sql_advisor_generate_args2cmd(self):
         self.assertIsInstance(cmd_args, str)
 
     def test_schema_sync_generate_args2cmd(self):
+        """
+        测试schema_sync参数转换
+        :return:
+        """
         args = {
             "sync-auto-inc": True,
             "sync-comments": True,
@@ -157,6 +170,34 @@ def test_schema_sync_generate_args2cmd(self):
         cmd_args = schema_sync.generate_args2cmd(args, True)
         self.assertIsInstance(cmd_args, str)
 
+    def test_binlog2ql_generate_args2cmd(self):
+        """
+        测试binlog2sql参数转换
+        :return:
+        """
+        args = {'conn_options': "-hmysql -uroot -p'123456' -P3306 ",
+                'stop_never': False,
+                'no-primary-key': False,
+                'flashback': True,
+                'back-interval': 0,
+                'start-file': 'mysql-bin.000043',
+                'start-position': 111,
+                'stop-file': '',
+                'stop-position': '',
+                'start-datetime': '',
+                'stop-datetime': '',
+                'databases': 'account_center',
+                'tables': 'ac_apps',
+                'only-dml': True,
+                'sql-type': 'UPDATE'}
+        self.sys_config.set('binlog2sql', '/opt/archery/src/plugins/binlog2sql/binlog2sql.py')
+        self.sys_config.get_all_config()
+        binlog2sql = Binlog2Sql()
+        cmd_args = binlog2sql.generate_args2cmd(args, False)
+        self.assertIsInstance(cmd_args, list)
+        cmd_args = binlog2sql.generate_args2cmd(args, True)
+        self.assertIsInstance(cmd_args, str)
+
     @patch('sql.plugins.plugin.subprocess')
     def test_execute_cmd(self, mock_subprocess):
         args = {"online-dsn": '',
@@ -171,7 +212,7 @@ def test_execute_cmd(self, mock_subprocess):
         cmd_args = soar.generate_args2cmd(args, True)
 
         mock_subprocess.Popen.return_value.communicate.return_value = ('some_stdout', 'some_stderr')
-        result = soar.execute_cmd(cmd_args, True)
+        stdout, stderr = soar.execute_cmd(cmd_args, True).communicate()
         mock_subprocess.Popen.assert_called_once_with(
             cmd_args,
             shell=True,
@@ -179,7 +220,7 @@ def test_execute_cmd(self, mock_subprocess):
             stderr=ANY,
             universal_newlines=ANY
         )
-        self.assertIn('some_stdout', result)
+        self.assertIn('some_stdout', stdout)
         # 异常
 
         mock_subprocess.Popen.side_effect = Exception('Boom! some exception!')
diff --git a/sql/sql_analyze.py b/sql/sql_analyze.py
index 7b3e9ff651..1f38e16703 100644
--- a/sql/sql_analyze.py
+++ b/sql/sql_analyze.py
@@ -70,7 +70,8 @@ def analyze(request):
         for row in rows:
             args['query'] = row['sql'].replace('"', '\\"').replace('`', '').replace('\n', ' ')
             cmd_args = soar.generate_args2cmd(args=args, shell=True)
-            row['report'] = soar.execute_cmd(cmd_args, shell=True)
+            stdout, stderr = soar.execute_cmd(cmd_args, shell=True).communicate()
+            row['report'] = stdout if stdout else stderr
         result = {"total": len(rows), "rows": rows}
     return HttpResponse(json.dumps(result, cls=ExtendJSONEncoder, bigint_as_string=True),
                         content_type='application/json')
diff --git a/sql/sql_optimize.py b/sql/sql_optimize.py
index b067aac89e..7567b3d878 100644
--- a/sql/sql_optimize.py
+++ b/sql/sql_optimize.py
@@ -70,7 +70,8 @@ def optimize_sqladvisor(request):
     cmd_args = sqladvisor.generate_args2cmd(args, shell=True)
     # 执行命令
     try:
-        result['data'] = sqladvisor.execute_cmd(cmd_args, shell=True)
+        stdout, stderr = sqladvisor.execute_cmd(cmd_args, shell=True).communicate()
+        result['data'] = f'{stdout}{stderr}'
     except RuntimeError as e:
         result['status'] = 1
         result['msg'] = str(e)
@@ -129,7 +130,8 @@ def optimize_soar(request):
     cmd_args = soar.generate_args2cmd(args, shell=True)
     # 执行命令
     try:
-        result['data'] = soar.execute_cmd(cmd_args, shell=True)
+        stdout, stderr = soar.execute_cmd(cmd_args, shell=True).communicate()
+        result['data'] = stdout if stdout else stderr
     except RuntimeError as e:
         result['status'] = 1
         result['msg'] = str(e)
diff --git a/sql/templates/binlog2sql.html b/sql/templates/binlog2sql.html
index 71a215a844..b3ee61a458 100644
--- a/sql/templates/binlog2sql.html
+++ b/sql/templates/binlog2sql.html
@@ -21,6 +21,16 @@ <h5 class="control-label text-bold">选择实例：</h5>
                             </select>
                         </div>
                     </div>
+                    <div class="form-group">
+                        <div class="form-group">
+                            <div class="checkbox">
+                                <label>
+                                    <input id="save_sql" type="checkbox">
+                                    是否保存到文件(异步操作)
+                                </label>
+                            </div>
+                        </div>
+                    </div>
                     <div class="form-group">
                         <h5 class="control-label text-bold">解析模式：</h5>
                         <div class="form-group">
@@ -36,10 +46,19 @@ <h5 class="control-label text-bold">解析模式：</h5>
                                     --flashback
                                 </label>
                             </div>
+                            <div class="form-group">
+                                <input type="number" class="form-control" id="back_interval"
+                                       placeholder="每一千行回滚SLEEP多少秒"
+                                       onkeyup="if(event.keyCode !=37 && event.keyCode != 39)value=value.replace(/\D/g,'')">
+                            </div>
                         </div>
                     </div>
                     <div class="form-group">
                         <h5 class="control-label text-bold">解析范围控制：</h5>
+                        <div class="form-group">
+                            <input type="number" class="form-control" id="num" placeholder="解析行数，默认500"
+                                   onkeyup="if(event.keyCode !=37 && event.keyCode != 39)value=value.replace(/\D/g,'')">
+                        </div>
                         <div class="form-group">
                             <select id="start_file" class="selectpicker form-control" required>
                                 <option value="is-empty" disabled="">起始解析文件:</option>
@@ -108,7 +127,11 @@ <h5 class="control-label text-bold">对象过滤：</h5>
                 </div>
                 <div class="panel-body">
                     <h5 class="control-label text-bold" style="color: red">
-                        <b>页面仅展示5000条，完整的SQL文件会保存到项目downloads目录，<a href="https://github.com/danfengcao/binlog2sql">项目地址</a></b>
+                        <b>前端展示数量由解析范围控制控制，如果勾选了保存到文件，则会异步获取完整的SQL文件，
+                            保存到项目downloads目录</b>
+                        <br>
+                        <br>
+                        <b>前往<a href="/admin/django_q/success/">django_q</a>查看执行结果</b>
                     </h5>
                     <br>
                     <table id="tb-binlog2sql" data-toggle="table" class="table table-condensed"></table>
@@ -174,7 +197,7 @@ <h5 class="control-label text-bold" style="color: red">
                         $("#start_file").empty();
                         $("#end_file").empty();
                         for (var i = 0; i < result.length; i++) {
-                            var name = "<option value=\"" + result[i]['Log_name'] + "\">" + result[i]['Log_name'] + "</option>";
+                            var name = "<option value=\"" + result[i]['Log_name'] + "\">" + result[i]['Log_name'] + '   Size:' + result[i]['File_size'] + "</option>";
                             $("#start_file").append(name);
                             $("#end_file").append(name);
                         }
@@ -227,15 +250,18 @@ <h5 class="control-label text-bold" style="color: red">
             if ($("#instance_name").val() && $("#start_file").val()) {
                 $(this).addClass('disabled');
                 $(this).prop('disabled', true);
-                alert('请耐心等待结果，可在对应目录获取生成的SQL文件');
+                alert('请耐心等待结果!');
                 $.ajax({
                     type: "post",
                     url: "/binlog2sql/sql/",
                     dataType: "json",
                     data: {
                         instance_name: $("#instance_name").val(),
+                        save_sql: document.getElementById("save_sql").checked,
                         no_pk: document.getElementById("no_pk").checked,
                         flashback: document.getElementById("flashback").checked,
+                        back_interval: $("#back_interval").val(),
+                        num: $("#num").val(),
                         start_file: $("#start_file").val(),
                         start_pos: $("#start_pos").val(),
                         end_file: $("#end_file").val(),
@@ -275,13 +301,42 @@ <h5 class="control-label text-bold" style="color: red">
                                 showToggle: true,                   //是否显示详细视图和列表视图的切换按钮
                                 cardView: false,                    //是否显示详细视图
                                 locale: 'zh-CN',                    //本地化
+                                detailView: true,                   //是否显示父子表
+                                //格式化详情
+                                detailFormatter: function (index, row) {
+                                    var html = [];
+                                    $.each(row, function (key, value) {
+                                        if (key === 'sql') {
+                                            var sql = window.sqlFormatter.format(value);
+                                            //替换所有的换行符
+                                            sql = sql.replace(/\r\n/g, "<br>");
+                                            sql = sql.replace(/\n/g, "<br>");
+                                            //替换所有的空格
+                                            sql = sql.replace(/\s/g, "&nbsp;");
+                                            html.push('<span>' + sql + '</span>');
+                                        }
+                                    });
+                                    return html.join('');
+                                },
                                 data: data.data,
                                 columns: [{
                                     title: 'BINLOG_INFO',
                                     field: 'binlog_info'
                                 }, {
                                     title: 'SQL',
-                                    field: 'sql'
+                                    field: 'sql',
+                                    formatter: function (value, row, index) {
+                                        if (value.length > 200) {
+                                            var sql = value.substr(0, 200) + '...';
+                                            return sql;
+                                        } else {
+                                            return value
+                                        }
+                                    }
+                                }, {
+                                    title: '完整SQL',
+                                    field: 'sql',
+                                    visible: false // 默认不显示
                                 }],
                                 onLoadSuccess: function () {
                                 },
@@ -294,8 +349,7 @@ <h5 class="control-label text-bold" style="color: red">
                         }
                     }
                 });
-            }
-            else {
+            } else {
                 alert("请选择实例和起始解析文件！")
             }
 
diff --git a/sql/urls.py b/sql/urls.py
index a8561b8604..ee6dd6bfb8 100644
--- a/sql/urls.py
+++ b/sql/urls.py
@@ -5,7 +5,7 @@
 
 import sql.sql_optimize
 from common import auth, config, workflow, dashboard, check
-from sql import views, sql_workflow, sql_analyze, query, slowlog, instance, db_diagnostic, resource_group, binlog2sql
+from sql import views, sql_workflow, sql_analyze, query, slowlog, instance, db_diagnostic, resource_group, binlog
 from sql.utils import jobs
 
 urlpatterns = [
@@ -89,8 +89,8 @@
     path('query/modifyprivileges/', query.modifyqueryprivileges),
     path('query/privaudit/', query.queryprivaudit),
 
-    path('binlog2sql/sql/', binlog2sql.binlog2sql),
-    path('binlog2sql/binlog_list/', binlog2sql.binlog_list),
+    path('binlog2sql/sql/', binlog.binlog2sql),
+    path('binlog2sql/binlog_list/', binlog.binlog_list),
 
     path('slowquery/review/', slowlog.slowquery_review),
     path('slowquery/review_history/', slowlog.slowquery_review_history),
diff --git a/sql/utils/binlog2sql/__init__.py b/sql/utils/binlog2sql/__init__.py
deleted file mode 100644
index 1f91234660..0000000000
--- a/sql/utils/binlog2sql/__init__.py
+++ /dev/null
@@ -1,6 +0,0 @@
-'''
-binlog2sql:
-Parse MySQL binlog to SQL you want.
-'''
-
-from .binlog2sql import Binlog2sql
diff --git a/sql/utils/binlog2sql/binlog2sql.py b/sql/utils/binlog2sql/binlog2sql.py
deleted file mode 100755
index 28c9c5b3bf..0000000000
--- a/sql/utils/binlog2sql/binlog2sql.py
+++ /dev/null
@@ -1,159 +0,0 @@
-#!/usr/bin/env python
-# -*- coding: utf-8 -*-
-
-import datetime
-import sys
-
-import pymysql
-from pymysqlreplication import BinLogStreamReader
-from pymysqlreplication.event import QueryEvent, RotateEvent, FormatDescriptionEvent
-
-from .binlog2sql_util import command_line_args, concat_sql_from_binlog_event, create_unique_file, temp_open, \
-    reversed_lines, is_dml_event, event_type
-
-
-class Binlog2sql(object):
-
-    def __init__(self, connection_settings, start_file=None, start_pos=None, end_file=None, end_pos=None,
-                 start_time=None, stop_time=None, only_schemas=None, only_tables=None, no_pk=False,
-                 flashback=False, stop_never=False, back_interval=1.0, only_dml=True, sql_type=None):
-        """
-        conn_setting: {'host': 127.0.0.1, 'port': 3306, 'user': user, 'passwd': passwd, 'charset': 'utf8'}
-        """
-
-        if not start_file:
-            raise ValueError('Lack of parameter: start_file')
-
-        self.conn_setting = connection_settings
-        self.start_file = start_file
-        self.start_pos = start_pos if start_pos else 4  # use binlog v4
-        self.end_file = end_file if end_file else start_file
-        self.end_pos = end_pos
-        if start_time:
-            self.start_time = datetime.datetime.strptime(start_time, "%Y-%m-%d %H:%M:%S")
-        else:
-            self.start_time = datetime.datetime.strptime('1980-01-01 00:00:00', "%Y-%m-%d %H:%M:%S")
-        if stop_time:
-            self.stop_time = datetime.datetime.strptime(stop_time, "%Y-%m-%d %H:%M:%S")
-        else:
-            self.stop_time = datetime.datetime.strptime('2999-12-31 00:00:00', "%Y-%m-%d %H:%M:%S")
-
-        self.only_schemas = only_schemas if only_schemas else None
-        self.only_tables = only_tables if only_tables else None
-        self.no_pk, self.flashback, self.stop_never, self.back_interval = (no_pk, flashback, stop_never, back_interval)
-        self.only_dml = only_dml
-        self.sql_type = [t.upper() for t in sql_type] if sql_type else []
-
-        self.binlogList = []
-        self.connection = pymysql.connect(**self.conn_setting)
-        with self.connection as cursor:
-            cursor.execute("SHOW MASTER STATUS")
-            self.eof_file, self.eof_pos = cursor.fetchone()[:2]
-            cursor.execute("SHOW MASTER LOGS")
-            bin_index = [row[0] for row in cursor.fetchall()]
-            if self.start_file not in bin_index:
-                raise ValueError('parameter error: start_file %s not in mysql server' % self.start_file)
-            binlog2i = lambda x: x.split('.')[1]
-            for binary in bin_index:
-                if binlog2i(self.start_file) <= binlog2i(binary) <= binlog2i(self.end_file):
-                    self.binlogList.append(binary)
-
-            cursor.execute("SELECT @@server_id")
-            self.server_id = cursor.fetchone()[0]
-            if not self.server_id:
-                raise ValueError('missing server_id in %s:%s' % (self.conn_setting['host'], self.conn_setting['port']))
-
-    def process_binlog(self, filename):
-        stream = BinLogStreamReader(connection_settings=self.conn_setting, server_id=self.server_id,
-                                    log_file=self.start_file, log_pos=self.start_pos, only_schemas=self.only_schemas,
-                                    only_tables=self.only_tables, resume_stream=True)
-
-        flag_last_event = False
-        e_start_pos, last_pos = stream.log_pos, stream.log_pos
-        # to simplify code, we do not use flock for tmp_file.
-        tmp_file = create_unique_file('%s.%s' % (self.conn_setting['host'], self.conn_setting['port']))
-        save_file = create_unique_file(filename)
-        with temp_open(tmp_file, "w") as f_tmp, open(save_file, "w") as f, self.connection as cursor:
-            for binlog_event in stream:
-                if not self.stop_never:
-                    try:
-                        event_time = datetime.datetime.fromtimestamp(binlog_event.timestamp)
-                    except OSError:
-                        event_time = datetime.datetime(1980, 1, 1, 0, 0)
-                    if (stream.log_file == self.end_file and stream.log_pos == self.end_pos) or \
-                            (stream.log_file == self.eof_file and stream.log_pos == self.eof_pos):
-                        flag_last_event = True
-                    elif event_time < self.start_time:
-                        if not (isinstance(binlog_event, RotateEvent)
-                                or isinstance(binlog_event, FormatDescriptionEvent)):
-                            last_pos = binlog_event.packet.log_pos
-                        continue
-                    elif (stream.log_file not in self.binlogList) or \
-                            (self.end_pos and stream.log_file == self.end_file and stream.log_pos > self.end_pos) or \
-                            (stream.log_file == self.eof_file and stream.log_pos > self.eof_pos) or \
-                            (event_time >= self.stop_time):
-                        break
-                    # else:
-                    #     raise ValueError('unknown binlog file or position')
-
-                if isinstance(binlog_event, QueryEvent) and binlog_event.query == 'BEGIN':
-                    e_start_pos = last_pos
-
-                if isinstance(binlog_event, QueryEvent) and not self.only_dml:
-                    sql = concat_sql_from_binlog_event(cursor=cursor, binlog_event=binlog_event,
-                                                       flashback=self.flashback, no_pk=self.no_pk)
-                    if sql:
-                        # print(sql)
-                        f.write(sql + '\n')
-                elif is_dml_event(binlog_event) and event_type(binlog_event) in self.sql_type:
-                    for row in binlog_event.rows:
-                        sql = concat_sql_from_binlog_event(cursor=cursor, binlog_event=binlog_event, no_pk=self.no_pk,
-                                                           row=row, flashback=self.flashback, e_start_pos=e_start_pos)
-                        if self.flashback:
-                            f_tmp.write(sql + '\n')
-                        else:
-                            # print(sql)
-                            f.write(sql + '\n')
-
-                if not (isinstance(binlog_event, RotateEvent) or isinstance(binlog_event, FormatDescriptionEvent)):
-                    last_pos = binlog_event.packet.log_pos
-                if flag_last_event:
-                    break
-
-            stream.close()
-            f_tmp.close()
-            if self.flashback:
-                self.print_rollback_sql(tmp_filename=tmp_file, filename=save_file)
-        return True
-
-    def print_rollback_sql(self, tmp_filename, filename):
-        """print rollback sql from tmp_file"""
-        sql_list = []
-        with open(tmp_filename, "rb") as f_tmp, open(filename, "w") as f:
-            batch_size = 1000
-            i = 0
-            for line in reversed_lines(f_tmp):
-                # print(line.rstrip())
-                f.write(line.rstrip() + '\n')
-                if i >= batch_size:
-                    i = 0
-                    if self.back_interval:
-                        # print('SELECT SLEEP(%s);' % self.back_interval)
-                        f.write('SELECT SLEEP(%s);' % self.back_interval + '\n')
-                else:
-                    i += 1
-        return sql_list
-
-    def __del__(self):
-        pass
-
-
-if __name__ == '__main__':
-    args = command_line_args(sys.argv[1:])
-    conn_setting = {'host': args.host, 'port': args.port, 'user': args.user, 'passwd': args.password, 'charset': 'utf8'}
-    binlog2sql = Binlog2sql(connection_settings=conn_setting, start_file=args.start_file, start_pos=args.start_pos,
-                            end_file=args.end_file, end_pos=args.end_pos, start_time=args.start_time,
-                            stop_time=args.stop_time, only_schemas=args.databases, only_tables=args.tables,
-                            no_pk=args.no_pk, flashback=args.flashback, stop_never=args.stop_never,
-                            back_interval=args.back_interval, only_dml=args.only_dml, sql_type=args.sql_type)
-    binlog2sql.process_binlog()
diff --git a/sql/utils/binlog2sql/binlog2sql_util.py b/sql/utils/binlog2sql/binlog2sql_util.py
deleted file mode 100755
index 34b55aaeb2..0000000000
--- a/sql/utils/binlog2sql/binlog2sql_util.py
+++ /dev/null
@@ -1,260 +0,0 @@
-# -*- coding: utf-8 -*-
-
-import os
-import sys
-import argparse
-import datetime
-from contextlib import contextmanager
-from pymysqlreplication.row_event import (
-    WriteRowsEvent,
-    UpdateRowsEvent,
-    DeleteRowsEvent,
-)
-from pymysqlreplication.event import QueryEvent
-
-if sys.version > '3':
-    PY3PLUS = True
-else:
-    PY3PLUS = False
-
-
-def is_valid_datetime(string):
-    try:
-        datetime.datetime.strptime(string, "%Y-%m-%d %H:%M:%S")
-        return True
-    except:
-        return False
-
-
-def create_unique_file(filename):
-    version = 0
-    result_file = filename
-    # if we have to try more than 1000 times, something is seriously wrong
-    while os.path.exists(result_file) and version < 1000:
-        result_file = filename + '.' + str(version)
-        version += 1
-    if version >= 1000:
-        raise OSError('cannot create unique file %s.[0-1000]' % filename)
-    return result_file
-
-
-@contextmanager
-def temp_open(filename, mode):
-    f = open(filename, mode)
-    try:
-        yield f
-    finally:
-        f.close()
-        os.remove(filename)
-
-
-def parse_args():
-    """parse args for binlog2sql"""
-
-    parser = argparse.ArgumentParser(description='Parse MySQL binlog to SQL you want', add_help=False)
-    connect_setting = parser.add_argument_group('connect setting')
-    connect_setting.add_argument('-h', '--host', dest='host', type=str,
-                                 help='Host the MySQL database server located', default='127.0.0.1')
-    connect_setting.add_argument('-u', '--user', dest='user', type=str,
-                                 help='MySQL Username to log in as', default='root')
-    connect_setting.add_argument('-p', '--password', dest='password', type=str,
-                                 help='MySQL Password to use', default='')
-    connect_setting.add_argument('-P', '--port', dest='port', type=int,
-                                 help='MySQL port to use', default=3306)
-    interval = parser.add_argument_group('interval filter')
-    interval.add_argument('--start-file', dest='start_file', type=str, help='Start binlog file to be parsed')
-    interval.add_argument('--start-position', '--start-pos', dest='start_pos', type=int,
-                          help='Start position of the --start-file', default=4)
-    interval.add_argument('--stop-file', '--end-file', dest='end_file', type=str,
-                          help="Stop binlog file to be parsed. default: '--start-file'", default='')
-    interval.add_argument('--stop-position', '--end-pos', dest='end_pos', type=int,
-                          help="Stop position. default: latest position of '--stop-file'", default=0)
-    interval.add_argument('--start-datetime', dest='start_time', type=str,
-                          help="Start time. format %%Y-%%m-%%d %%H:%%M:%%S", default='')
-    interval.add_argument('--stop-datetime', dest='stop_time', type=str,
-                          help="Stop Time. format %%Y-%%m-%%d %%H:%%M:%%S;", default='')
-    parser.add_argument('--stop-never', dest='stop_never', action='store_true', default=False,
-                        help="Continuously parse binlog. default: stop at the latest event when you start.")
-    parser.add_argument('--help', dest='help', action='store_true', help='help information', default=False)
-
-    schema = parser.add_argument_group('schema filter')
-    schema.add_argument('-d', '--databases', dest='databases', type=str, nargs='*',
-                        help='dbs you want to process', default='')
-    schema.add_argument('-t', '--tables', dest='tables', type=str, nargs='*',
-                        help='tables you want to process', default='')
-
-    event = parser.add_argument_group('type filter')
-    event.add_argument('--only-dml', dest='only_dml', action='store_true', default=False,
-                       help='only print dml, ignore ddl')
-    event.add_argument('--sql-type', dest='sql_type', type=str, nargs='*', default=['INSERT', 'UPDATE', 'DELETE'],
-                       help='Sql type you want to process, support INSERT, UPDATE, DELETE.')
-
-    # exclusive = parser.add_mutually_exclusive_group()
-    parser.add_argument('-K', '--no-primary-key', dest='no_pk', action='store_true',
-                        help='Generate insert sql without primary key if exists', default=False)
-    parser.add_argument('-B', '--flashback', dest='flashback', action='store_true',
-                        help='Flashback data to start_position of start_file', default=False)
-    parser.add_argument('--back-interval', dest='back_interval', type=float, default=1.0,
-                        help="Sleep time between chunks of 1000 rollback sql. set it to 0 if do not need sleep")
-    return parser
-
-
-def command_line_args(args):
-    need_print_help = False if args else True
-    parser = parse_args()
-    args = parser.parse_args(args)
-    if args.help or need_print_help:
-        parser.print_help()
-        sys.exit(1)
-    if not args.start_file:
-        raise ValueError('Lack of parameter: start_file')
-    if args.flashback and args.stop_never:
-        raise ValueError('Only one of flashback or stop-never can be True')
-    if args.flashback and args.no_pk:
-        raise ValueError('Only one of flashback or no_pk can be True')
-    if (args.start_time and not is_valid_datetime(args.start_time)) or \
-            (args.stop_time and not is_valid_datetime(args.stop_time)):
-        raise ValueError('Incorrect datetime argument')
-    return args
-
-
-def compare_items(items):
-    # caution: if v is NULL, may need to process
-    (k, v) = items
-    if v is None:
-        return '`%s` IS %%s' % k
-    else:
-        return '`%s`=%%s' % k
-
-
-def fix_object(value):
-    """Fixes python objects so that they can be properly inserted into SQL queries"""
-    if isinstance(value, set):
-        value = ','.join(value)
-    if PY3PLUS and isinstance(value, bytes):
-        return value.decode('utf-8', errors='ignore')
-    elif not PY3PLUS and isinstance(value, unicode):
-        return value.encode('utf-8')
-    else:
-        return value
-
-
-def is_dml_event(event):
-    if isinstance(event, WriteRowsEvent) or isinstance(event, UpdateRowsEvent) or isinstance(event, DeleteRowsEvent):
-        return True
-    else:
-        return False
-
-
-def event_type(event):
-    t = None
-    if isinstance(event, WriteRowsEvent):
-        t = 'INSERT'
-    elif isinstance(event, UpdateRowsEvent):
-        t = 'UPDATE'
-    elif isinstance(event, DeleteRowsEvent):
-        t = 'DELETE'
-    return t
-
-
-def concat_sql_from_binlog_event(cursor, binlog_event, row=None, e_start_pos=None, flashback=False, no_pk=False):
-    if flashback and no_pk:
-        raise ValueError('only one of flashback or no_pk can be True')
-    if not (isinstance(binlog_event, WriteRowsEvent) or isinstance(binlog_event, UpdateRowsEvent)
-            or isinstance(binlog_event, DeleteRowsEvent) or isinstance(binlog_event, QueryEvent)):
-        raise ValueError('binlog_event must be WriteRowsEvent, UpdateRowsEvent, DeleteRowsEvent or QueryEvent')
-
-    sql = ''
-    if isinstance(binlog_event, WriteRowsEvent) or isinstance(binlog_event, UpdateRowsEvent) \
-            or isinstance(binlog_event, DeleteRowsEvent):
-        pattern = generate_sql_pattern(binlog_event, row=row, flashback=flashback, no_pk=no_pk)
-        sql = cursor.mogrify(pattern['template'], pattern['values'])
-        time = datetime.datetime.fromtimestamp(binlog_event.timestamp)
-        sql += ' #start %s end %s time %s' % (e_start_pos, binlog_event.packet.log_pos, time)
-    elif flashback is False and isinstance(binlog_event, QueryEvent) and binlog_event.query != 'BEGIN' \
-            and binlog_event.query != 'COMMIT':
-        if binlog_event.schema:
-            sql = 'USE {0};\n'.format(binlog_event.schema)
-        sql += '{0};'.format(fix_object(binlog_event.query))
-
-    return sql
-
-
-def generate_sql_pattern(binlog_event, row=None, flashback=False, no_pk=False):
-    template = ''
-    values = []
-    if flashback is True:
-        if isinstance(binlog_event, WriteRowsEvent):
-            template = 'DELETE FROM `{0}`.`{1}` WHERE {2} LIMIT 1;'.format(
-                binlog_event.schema, binlog_event.table,
-                ' AND '.join(map(compare_items, row['values'].items()))
-            )
-            values = map(fix_object, row['values'].values())
-        elif isinstance(binlog_event, DeleteRowsEvent):
-            template = 'INSERT INTO `{0}`.`{1}`({2}) VALUES ({3});'.format(
-                binlog_event.schema, binlog_event.table,
-                ', '.join(map(lambda key: '`%s`' % key, row['values'].keys())),
-                ', '.join(['%s'] * len(row['values']))
-            )
-            values = map(fix_object, row['values'].values())
-        elif isinstance(binlog_event, UpdateRowsEvent):
-            template = 'UPDATE `{0}`.`{1}` SET {2} WHERE {3} LIMIT 1;'.format(
-                binlog_event.schema, binlog_event.table,
-                ', '.join(['`%s`=%%s' % x for x in row['before_values'].keys()]),
-                ' AND '.join(map(compare_items, row['after_values'].items())))
-            values = map(fix_object, list(row['before_values'].values()) + list(row['after_values'].values()))
-    else:
-        if isinstance(binlog_event, WriteRowsEvent):
-            if no_pk:
-                # print binlog_event.__dict__
-                # tableInfo = (binlog_event.table_map)[binlog_event.table_id]
-                # if tableInfo.primary_key:
-                #     row['values'].pop(tableInfo.primary_key)
-                if binlog_event.primary_key:
-                    row['values'].pop(binlog_event.primary_key)
-
-            template = 'INSERT INTO `{0}`.`{1}`({2}) VALUES ({3});'.format(
-                binlog_event.schema, binlog_event.table,
-                ', '.join(map(lambda key: '`%s`' % key, row['values'].keys())),
-                ', '.join(['%s'] * len(row['values']))
-            )
-            values = map(fix_object, row['values'].values())
-        elif isinstance(binlog_event, DeleteRowsEvent):
-            template = 'DELETE FROM `{0}`.`{1}` WHERE {2} LIMIT 1;'.format(
-                binlog_event.schema, binlog_event.table, ' AND '.join(map(compare_items, row['values'].items())))
-            values = map(fix_object, row['values'].values())
-        elif isinstance(binlog_event, UpdateRowsEvent):
-            template = 'UPDATE `{0}`.`{1}` SET {2} WHERE {3} LIMIT 1;'.format(
-                binlog_event.schema, binlog_event.table,
-                ', '.join(['`%s`=%%s' % k for k in row['after_values'].keys()]),
-                ' AND '.join(map(compare_items, row['before_values'].items()))
-            )
-            values = map(fix_object, list(row['after_values'].values()) + list(row['before_values'].values()))
-
-    return {'template': template, 'values': list(values)}
-
-
-def reversed_lines(fin):
-    """Generate the lines of file in reverse order."""
-    part = ''
-    for block in reversed_blocks(fin):
-        if PY3PLUS:
-            block = block.decode("utf-8", errors='ignore')
-        for c in reversed(block):
-            if c == '\n' and part:
-                yield part[::-1]
-                part = ''
-            part += c
-    if part:
-        yield part[::-1]
-
-
-def reversed_blocks(fin, block_size=4096):
-    """Generate blocks of file's contents in reverse order."""
-    fin.seek(0, os.SEEK_END)
-    here = fin.tell()
-    while 0 < here:
-        delta = min(block_size, here)
-        here -= delta
-        fin.seek(here, os.SEEK_SET)
-        yield fin.read(delta)