Add support for minio-s3lat

This commit is contained in:
Quentin 2022-09-23 18:09:54 +02:00
parent c9cbe5fc52
commit 4a02f16489
Signed by: quentin
GPG key ID: E9602264D639FF68
3 changed files with 34 additions and 7 deletions

View file

@ -16,8 +16,8 @@ client = minio.Minio(
secret_key="minioadmin", secret_key="minioadmin",
secure=False, secure=False,
http_client=urllib3.PoolManager( http_client=urllib3.PoolManager(
timeout=5, timeout=2,
retries=1, retries=False,
) )
) )

View file

@ -1,16 +1,24 @@
import os import os
from os.path import exists from os.path import exists
from pathlib import Path from pathlib import Path
from fragments import shared, garage from fragments import shared, minio, garage
s3bin = Path(os.path.dirname(__file__)) / "../../benchmarks/s3lat/s3lat" s3bin = Path(os.path.dirname(__file__)) / "../../benchmarks/s3lat/s3lat"
def common():
out = Path(shared.storage_path) / "s3lat.csv"
shared.log(f"launching s3lat ({s3bin})")
shared.exec(f"{s3bin} > {out}")
shared.log(f"execution done, output written to {out}")
def on_garage(): def on_garage():
os.environ['AWS_ACCESS_KEY_ID'] = garage.key.access_key_id os.environ['AWS_ACCESS_KEY_ID'] = garage.key.access_key_id
os.environ['AWS_SECRET_ACCESS_KEY'] = garage.key.secret_access_key os.environ['AWS_SECRET_ACCESS_KEY'] = garage.key.secret_access_key
os.environ['ENDPOINT'] = "localhost:3900" os.environ['ENDPOINT'] = "localhost:3900"
common()
out = Path(shared.storage_path) / "s3lat.csv" def on_minio():
shared.log(f"launching s3lat ({s3bin})") os.environ['AWS_ACCESS_KEY_ID'] = minio.access_key
shared.exec(f"{s3bin} > {out}") os.environ['AWS_SECRET_ACCESS_KEY'] = minio.secret_key
shared.log(f"execution done, output written to {out}") os.environ['ENDPOINT'] = "localhost:9000"
common()

19
scenarios/minio-s3lat Executable file
View file

@ -0,0 +1,19 @@
#!/usr/bin/env python3
from fragments import minio, s3lat, shared, flavor
import sys
for fl in sys.argv[1:]:
if fl in flavor.minio:
minio.version = flavor.minio[fl]
if shared.id() == 1:
minio.deploy_coord()
s3lat.on_minio()
minio.delete_sync_bucket()
minio.destroy()
else:
minio.deploy_follow()
minio.sync_on_bucket_down()
minio.destroy()
shared.log("bye")