我写了一些小代码来控制谷歌云平台上的多个计算引擎.整个文件在这里是github.

该部分导致的问题是gcloud compute ssh如下

def upload_file(self,projectname):
    var = raw_input("Upload file with name: " + projectname + " will remove all file and directory with same name in the instance. Are you sure? (y/n)")
    if var.lower().strip() != "y":
        print "Abort uploading."
        return
    is_zip = False
    if projectname.split('.')[1] == "zip":
        is_zip = True
    fullpath_projectname = __location__ + "/" + projectname
    if os.path.isfile(fullpath_projectname):
        all_instances = self.search_any('instances',filter="labels.type=" + self.working_group_label)
        all_instances_name = [x['name'] for x in all_instances]


        i = 0
        for instance in all_instances_name:

            temp_command = 'gcloud_command_' + str(i) 
            i += 1
            temp_instance = user_name + "@" + instance
            temp_file_path = '/home/' + user_name + '/'

            command_arr = []
            command_arr.append('call gcloud compute ssh ' + temp_instance + ' --zone ' + zone + ' --command "cd ' + temp_file_path + '; sudo rm -rf ' + temp_file_path + projectname.split('.')[0] + '; sudo rm -f ' + temp_file_path + projectname.split('.')[0] + '*"\n')
            command_arr.append('call gcloud compute scp "' + fullpath_projectname + '" ' + temp_instance + ':' + temp_file_path + '\n')
            if is_zip:
                command_arr.append('call gcloud compute ssh ' + temp_instance + ' --zone ' + zone + ' ' + ' --command "cd ' + temp_file_path + '; sudo unzip ' + temp_file_path + projectname + '"' + '\n')
            with open(os.path.join(__location__,'bat/' + temp_command + '.bat'),'w') as bat:
                bat.writelines(command_arr)
            subprocess.Popen(os.path.join(__location__,shell=True)

此部分用于将相同文件(通常为.zip)上载到具有相同标记的所有实例.但是,在我的本地计算机上执行此操作会跳出很多警报,要求我保存ssh指纹.

像这样,

最初它是一个小工具,为了我自己的方便,为了运行多个计算引擎来查询在线数据(我希望有多个IP,以避免被归类为DDoS).但现在我需要与其他团队分享这一点,以便捆绑警报会导致其他人混淆.

我可以手动逐个缓存它,但对其他人来说不方便.

我试图通过改变最后一行来回答缓存

proc = subprocess.Popen(os.path.join(__location__,shell=True)
proc.communicate(input='y')

但是这使得所有上传只是一个接一个地进行,对于许多实例来说这是非常慢的.