upload_arm_templates.py 文件源码

def upload_template_files(*args):

    print('\n== UPLOAD ARM TEMPLATES ==')

    parser = argparse.ArgumentParser(description='Upload ARM Templates')
    parser.add_argument('--name', metavar='NAME', required=True, help='Name of the thing being uploaded (in CamelCase)')
    parser.add_argument('--src', metavar='PATH', required=True, help='Path to the directory containing ARM templates to upload. Subdirectories will automatically be crawled.')
    parser.add_argument('--api-version', metavar='VERSION', required=True, help='API version for the templates being uploaded in yyyy-MM-dd format. (ex: 2016-07-01)')
    args = parser.parse_args(args)

    name = args.name
    api_version = args.api_version
    src = args.src

    _upload_templates(name, api_version, src)

    from concurrent.futures import ThreadPoolExecutor, as_completed
    with ThreadPoolExecutor(max_workers=40) as executor:
        tasks = [executor.submit(lambda cmd: os.system(cmd), u) for u in uploads]
        for t in as_completed(tasks):
            t.result() # don't use the result but expose exceptions from the threads