def create_queues()

in clone_mediaconvert_resources/clone_mediaconvert_resources.py [0:0]


def create_queues(destination_client, queue_file):
    with open(queue_file) as queues:
        queue_data = json.load(queues)
    try:
        for queue in queue_data:
            response = destination_client.create_queue(
                Name=queue['Name'],
                Description=queue['Description']
            )
        account_id = response['Queue']['Arn'].split('/')[0].split(":")[4]
        resource_type = response['Queue']['Arn'].split('/')[0].split(":")[5]
        create_resource_tags(destination_client, account_id, resource_type)

    except botocore.exceptions.ClientError as error:
        if error.response['Error']['Code'] == 'TooManyRequestsException':
            print("Number of queue allowed exceeded, please open a service quota request")
        elif error.response['Error']['Code'] == 'AccessDeniedException':
            print("No permissions to access the MediaConvert API and create queues,"
                  " please check the AWS CLI credentials")
            exit(-1)