annotate galaxy-tools/biobank/exporter/export_titer_plates.py @ 0:ba6cf6ede027 draft default tip

Uploaded
author ric
date Wed, 28 Sep 2016 06:03:30 -0400
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
1 import logging, csv, argparse, sys, os
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
2
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
3 from bl.vl.kb import KnowledgeBase as KB
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
4 import bl.vl.kb.drivers.omero.utils as vlu
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
5
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
6 LOG_FORMAT = '%(asctime)s|%(levelname)-8s|%(message)s'
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
7 LOG_DATEFMT = '%Y-%m-%d %H:%M:%S'
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
8 LOG_LEVELS = ['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL']
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
9
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
10 CSV_FIELDS = ['label', 'barcode', 'rows', 'columns', 'plate_status']
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
11
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
12 def make_parser():
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
13 parser = argparse.ArgumentParser(description='dump all TiterPlate objects to a TSV file')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
14 parser.add_argument('--logfile', type=str, help='log file (default=stderr)')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
15 parser.add_argument('--loglevel', type=str, choices=LOG_LEVELS,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
16 help='logging level', default='INFO')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
17 parser.add_argument('-H', '--host', type=str, help='omero hostname')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
18 parser.add_argument('-U', '--user', type=str, help='omero user')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
19 parser.add_argument('-P', '--passwd', type=str, help='omero password')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
20 parser.add_argument('--ofile', type=str, help='output file',
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
21 required=True)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
22 return parser
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
23
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
24 def main(argv):
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
25 parser = make_parser()
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
26 args = parser.parse_args(argv)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
27
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
28 log_level = getattr(logging, args.loglevel)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
29 kwargs = {'format' : LOG_FORMAT,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
30 'datefmt' : LOG_DATEFMT,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
31 'level' : log_level}
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
32 if args.logfile:
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
33 kwargs['filename'] = args.logfile
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
34 logging.basicConfig(**kwargs)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
35 logger = logging.getLogger()
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
36
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
37 try:
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
38 host = args.host or vlu.ome_host()
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
39 user = args.user or vlu.ome_user()
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
40 passwd = args.passwd or vlu.ome_passwd
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
41 except ValueError, ve:
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
42 logger.critical(ve)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
43 sys.exit(ve)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
44
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
45 kb = KB(driver='omero')(host, user, passwd)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
46 logging.info('Loading TiterPlate objects')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
47 plates = kb.get_objects(kb.TiterPlate)
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
48 logging.info('Loaded %d objects' % len(plates))
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
49
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
50 with open(args.ofile, 'w') as ofile:
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
51 writer = csv.DictWriter(ofile, CSV_FIELDS, delimiter='\t')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
52 writer.writeheader()
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
53 for pl in plates:
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
54 logger.debug('Dumping plate %d/%d' % (plates.index(pl) + 1,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
55 len(plates)))
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
56 writer.writerow({'label' : pl.label,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
57 'barcode' : pl.barcode,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
58 'rows' : pl.rows,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
59 'columns' : pl.columns,
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
60 'plate_status' : pl.status.enum_label()})
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
61 logger.info('Job done')
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
62
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
63
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
64
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
65
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
66 if __name__ == '__main__':
ba6cf6ede027 Uploaded
ric
parents:
diff changeset
67 main(sys.argv[1:])