wonsun
03/06/2023, 7:05 AMimport boto3
from prefect_aws import AwsCredentials
@flow
def check_conndition():
ac_block = AwsCredentials.load('my_block')
s3 = boto3.resource('s3', aws_access_key_id=ac_block.aws_access_key_id, aws_secret_access_key=ac_block.aws_secret_access_key)
bucket = s3.Bucket('my_existing_bucket')
obj_list = []
for obj_summary in bucket.objects.all(): #error occurring point
obj_list.append(obj_summary.key)
if __name__=='__main__':
check_condition()