diff options
author | Binh Le <lebinh.it@gmail.com> | 2014-04-09 10:07:32 +0700 |
---|---|---|
committer | Binh Le <lebinh.it@gmail.com> | 2014-04-09 10:07:32 +0700 |
commit | e409482be582eedc08ed4a97687305e422b1aa2b (patch) | |
tree | b48e3de60a9f8f5167f4813f6aa9ec5f82e77a32 | |
parent | 7b154b1af413d07a06b473de296fa91af6cdf37c (diff) | |
parent | a546be9e6d92137bf3484038b9408738ab7bcd74 (diff) |
Merge pull request #29 from jreese/groupby
Support multiple fields in --group-by
-rwxr-xr-x | ngxtop/ngxtop.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/ngxtop/ngxtop.py b/ngxtop/ngxtop.py index 428af12..afb5bc3 100755 --- a/ngxtop/ngxtop.py +++ b/ngxtop/ngxtop.py @@ -210,6 +210,7 @@ class SQLProcessor(object): def process(self, records): self.begin = time.time() insert = 'insert into log (%s) values (%s)' % (self.column_list, self.holder_list) + logging.info('sqlite insert: %s', insert) with closing(self.conn.cursor()) as cursor: for r in records: cursor.execute(insert, r) @@ -300,7 +301,12 @@ def build_processor(arguments): for label, query in report_queries: logging.info('query for "%s":\n %s', label, query) - processor = SQLProcessor(report_queries, fields) + + processor_fields = [] + for field in fields: + processor_fields.extend(field.split(',')) + + processor = SQLProcessor(report_queries, processor_fields) return processor |