def parse_arguments(argv):
parser = argparse.ArgumentParser(description='...')
parser.add_argument(
'-b', '--brokers', dest='brokers', required=True, type=lambda x: x.split(','),
help='Kafka brokers to bootstrap from as a comma separated list of <host>:<port>')
parser.add_argument(
'-m', '--max-request-size', dest='max_request_size', type=int, default=4*1024*1024*10,
help='Max size of requets sent to the kafka broker'
+ 'Defaults to 40MB.')
parser.add_argument(
'-w', '--num-workers', dest='n_workers', type=int, default=5,
help='Number of workers to issue elasticsearch queries in parallel. '
+ 'Defaults to 5.')
parser.add_argument(
'-v', '--verbose', dest='verbose', default=False, action='store_true',
help='Increase logging to INFO')
parser.add_argument(
'-vv', '--very-verbose', dest='very_verbose', default=False, action='store_true',
help='Increase logging to DEBUG')
args = parser.parse_args(argv)
return dict(vars(args))
评论列表
文章目录