Skip to content

Commit 1db05ff

Browse files
committed
Add CLI interface to benchmark.py
1 parent 962320a commit 1db05ff

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

benchmark.py

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ def bench_basic_publish(iterations=10000, bytes=256):
5555
iterations * t_publish_librabbit.timeit(number=iterations)/iterations)
5656
)
5757

58-
def bench_basic_consume(iterations=10000):
58+
def bench_basic_consume(iterations=10000, bytes=None):
5959
context = {"its": (iterations/2)/10}
6060
t_consume_amqp = timeit.Timer(stmt=CONSUME % context,
6161
setup=INIT_AMQP)
@@ -72,7 +72,16 @@ def bench_basic_consume(iterations=10000):
7272
benchmarks = [bench_basic_publish, bench_basic_consume]
7373

7474
if __name__ == "__main__":
75+
import argparse
76+
77+
parser = argparse.ArgumentParser(description='Runs benchmark against local RabbitMQ instance.')
78+
parser.add_argument('--iters', metavar='N', type=int, default=100000,
79+
help='Number of iterations')
80+
parser.add_argument('--bytes', metavar='B', type=int,
81+
default=256, help='Message size')
82+
83+
args = parser.parse_args()
7584
for benchmark in benchmarks:
76-
benchmark(100000)
85+
benchmark(args.iters, bytes=args.bytes)
7786

7887

0 commit comments

Comments
 (0)