|
sawine@0
|
1 |
import csv
|
|
sawine@0
|
2 |
|
|
sawine@0
|
3 |
dflow_fields={"log_time": 0, "call_sign": 1, "adep": 2,
|
|
sawine@0
|
4 |
"rwy": 3, "ades": 4, "etot": 5, "atot": 6, "flow_point": 7,
|
|
sawine@0
|
5 |
"flow_time": 8, "atd": 9}
|
|
sawine@0
|
6 |
|
|
sawine@0
|
7 |
def parse_files(args):
|
|
sawine@0
|
8 |
plans = []
|
|
sawine@0
|
9 |
for file in args:
|
|
sawine@0
|
10 |
reader = csv.reader(open(file, "rb"), delimiter=",", quoting=csv.QUOTE_NONE, quotechar="'")
|
|
sawine@0
|
11 |
for row in reader:
|
|
sawine@0
|
12 |
plans.append(row)
|
|
sawine@0
|
13 |
return plans
|
|
sawine@0
|
14 |
|
|
sawine@0
|
15 |
def parse_pipe(args):
|
|
sawine@0
|
16 |
plans = []
|
|
sawine@0
|
17 |
row = []
|
|
sawine@0
|
18 |
input_str = "".join(args)
|
|
sawine@0
|
19 |
values = input_str.split(",")
|
|
sawine@0
|
20 |
for v in values:
|
|
sawine@0
|
21 |
row.append(v)
|
|
sawine@0
|
22 |
if len(row) == len(dflow_fields):
|
|
sawine@0
|
23 |
plans.append(row)
|
|
sawine@0
|
24 |
row = []
|
|
sawine@0
|
25 |
return plans
|
|
sawine@0
|
26 |
|
|
sawine@0
|
27 |
def print_logs(plans):
|
|
sawine@0
|
28 |
plan_str = str()
|
|
sawine@0
|
29 |
for plan in plans:
|
|
sawine@0
|
30 |
if len(plan_str) > 0:
|
|
sawine@0
|
31 |
plan_str += "\n"
|
|
sawine@0
|
32 |
plan_str += ",".join(plan)
|
|
sawine@0
|
33 |
print plan_str
|