def action_aggregate(reader, *args):
all_aggregated = aggregated_records(reader)<EOL>first_row = next(all_aggregated)<EOL>keys = sorted(first_row.keys())<EOL>print(*keys, sep='<STR_LIT:\t>')<EOL>iterable = chain([first_row], all_aggregated)<EOL>for item in iterable:<EOL><INDENT>print(*[item[k] for k in keys], sep='<STR_LIT:\t>')<EOL><DEDENT>
Aggregate flow records by 5-tuple and print a tab-separated stream