query_tracker.py 文件源码

def execute_insert_sql(self, *args, **kwargs):
    stack_trace = traceback.format_stack()
    query_dict = {
        'query': [],
        'query_type': QUERY_TYPE_WRITE,
        'traceback': stack_trace,
        'model': "%s.%s" % (self.query.model.__module__, self.query.model.__name__),
        'start_time': datetime.datetime.now(),
    }
    for sql, params in self.as_sql():
        query_dict['query'].append(sql % params)

    try:
        return self._snoopy_execute_insert_sql(*args, **kwargs)
    finally:
        # This gets called just before the `return`
        query_dict['end_time'] = datetime.datetime.now()
        SnoopyRequest.record_query_data(query_dict)