in sample-demo-app/aws_python_sample_application/task_publisher.py [0:0]
def publish_image_transform_task(self, num_of_tasks=10):
images = self._list_image_on_s3()
if len(images) == 0:
print("No images in bucket. Uploading example image...")
self._upload_images_onto_s3()
return
print("Start publishing task onto sqs...")
for i in range(num_of_tasks):
lucky_number = random.randint(0, len(images)-1)
self._send_sqs_message(str(images[lucky_number]))