def publish_image_transform_task()

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]))