This commit is contained in:
Julius Unverfehrt 2022-02-24 16:32:23 +01:00
parent 7d6dbabf30
commit 0114977075

View File

@ -6,8 +6,8 @@ from pyinfra.storage.storages import get_s3_storage
def build_message_bodies():
minio_client = get_s3_storage()
for dossier_id, pdf_name in minio_client.list_bucket_files(CONFIG.test.bucket):
storage = get_s3_storage()
for dossier_id, pdf_name in storage.list_bucket_files(CONFIG.test.bucket):
file_id = pdf_name.split(".")[0]
yield json.dumps({"dossierId": dossier_id, "fileId": file_id})