|
0
|
1 '''
|
|
|
2 '''
|
|
|
3
|
|
|
4 import argparse, csv, sys
|
|
|
5
|
|
|
6 from bl.vl.kb import KnowledgeBase as KB
|
|
|
7 import bl.vl.utils.ome_utils as vlu
|
|
|
8 from bl.vl.utils import get_logger, LOG_LEVELS
|
|
|
9
|
|
|
10
|
|
|
11 def make_parser():
|
|
|
12 parser = argparse.ArgumentParser(description='retrieve studies details')
|
|
|
13 parser.add_argument('--logfile', type=str, help='log file (default=stderr)')
|
|
|
14 parser.add_argument('--loglevel', type=str, choices=LOG_LEVELS,
|
|
|
15 help='logging level (default=INFO)', default='INFO')
|
|
|
16 parser.add_argument('-H', '--host', type=str, help='omero hostname')
|
|
|
17 parser.add_argument('-U', '--user', type=str, help='omero user')
|
|
|
18 parser.add_argument('-P', '--passwd', type=str, help='omero passwd')
|
|
|
19 parser.add_argument('--out_file', type=str, required=True,
|
|
|
20 help='output file with studies details')
|
|
|
21 return parser
|
|
|
22
|
|
|
23
|
|
|
24 def main(argv):
|
|
|
25 parser = make_parser()
|
|
|
26 args = parser.parse_args(argv)
|
|
|
27
|
|
|
28 logger = get_logger('get_studies', level=args.loglevel,
|
|
|
29 filename=args.logfile)
|
|
|
30
|
|
|
31 try:
|
|
|
32 host = args.host or vlu.ome_host()
|
|
|
33 user = args.user or vlu.ome_user()
|
|
|
34 passwd = args.passwd or vlu.ome_passwd()
|
|
|
35 except ValueError, ve:
|
|
|
36 logger.critical(ve)
|
|
|
37 sys.exit(ve)
|
|
|
38
|
|
|
39 kb = KB(driver='omero')(host, user, passwd)
|
|
|
40
|
|
|
41 logger.info('Retrieving studies')
|
|
|
42 studies = kb.get_objects(kb.Study)
|
|
|
43 logger.info('Retrieved {} studies'.format(len(studies)))
|
|
|
44 records = []
|
|
|
45 for s in studies:
|
|
|
46 enr = kb.get_enrolled(s)
|
|
|
47 rec = {'label': s.label,
|
|
|
48 'description': s.description,
|
|
|
49 'enrolled': len(enr)}
|
|
|
50 records.append(rec)
|
|
|
51
|
|
|
52 with open(args.out_file, 'w') as outfile:
|
|
|
53 writer = csv.DictWriter(outfile, ['label', 'description', 'enrolled'],
|
|
|
54 delimiter='\t')
|
|
|
55 # writer.writeheader()
|
|
|
56 writer.writerows(sorted(records, key=lambda key: key['label']))
|
|
|
57
|
|
|
58 if __name__ == '__main__':
|
|
|
59 main(sys.argv[1:])
|
