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