powercliのinvoke-vmscriptに相当するpyvmomiとは何ですか？

Question

私は既存のpowercliデプロイメントスクリプトをpython/pyvmomiに移動し、マルチスレッド（多くのVMをデプロイする）を探しています。元のスクリプトでは、Invoke-VMScriptをかなり使用して、VMware Toolsを使用してpowershellフラグメントを各ゲストにプッシュします。

pyvmomiの同等の機能は何ですか？具体的には - Tools（ゲストのネットワークではない）経由でゲストにpowershellスクリプトを送信し、提供された資格情報で実行してから出力を収集しますか？

私はprocessManager.StartProgramInGuestを見ることができますが、それはちょっとした3段階のプロセス（アップロードファイル、ファイルの実行、リダイレクトされた結果のダウンロード）のようです - バックグラウンドでpowercliがやっていることですか？

Answer 1

私は何とか完全な例を見つけることができなかったので、いくつかの閉鎖を提供するために、ここに私の最初の取り組みがあります。これはすでにSmartConnectを使用してvcenterサーバーに接続しているクラスの一部で、self.siに設定されています。まだ実際には多くのエラーチェックはしていません。待機して出力を取得するか、コマンドを起動した後に戻るかを選択できます。 remote_cmdはもともとpyvmomi-community-samplesから来ており、現在は2つの方法の間に重複があります。

def invoke_vmscript(self, vm_username, vm_password, vm_name, script_content, wait_for_output=False): 

    script_content_crlf = script_content.replace('\n', '\r\n') 

    content = self.si.content 
    creds = vim.vm.guest.NamePasswordAuthentication(username=vm_username, password=vm_password) 
    vm = self.get_vm(vm_name) 
    logger.debug("Invoke-VMScript Started for %s", vm_name) 
    logger.debug("CREATING TEMP OUTPUT DIR") 
    file_manager = content.guestOperationsManager.fileManager 

    temp_dir = file_manager.CreateTemporaryDirectoryInGuest(vm, creds, "nodebldr_", 
                  "_scripts") 
    try: 
     file_manager.MakeDirectoryInGuest(vm, creds, temp_dir, False) 
    except vim.fault.FileAlreadyExists: 
     pass 
    temp_script_file = file_manager.CreateTemporaryFileInGuest(vm, creds, "nodebldr_", 
                   "_script.ps1", 
                   temp_dir) 
    temp_output_file = file_manager.CreateTemporaryFileInGuest(vm, creds, "nodebldr_", 
                   "_output.txt", 
                   temp_dir) 
    logger.debug("SCRIPT FILE: " + temp_script_file) 
    logger.debug("OUTPUT FILE: " + temp_output_file) 
    file_attribute = vim.vm.guest.FileManager.FileAttributes() 
    url = file_manager.InitiateFileTransferToGuest(vm, creds, temp_script_file, 
                file_attribute, 
                len(script_content_crlf), True) 
    logger.debug("UPLOAD SCRIPT TO: " + url) 
    r = requests.put(url, data=script_content_crlf, verify=False) 
    if not r.status_code == 200: 
     logger.debug("Error while uploading file") 
    else: 
     logger.debug("Successfully uploaded file") 

    self.remote_cmd(vm_name, vm_username, vm_password, 'C:\\WINDOWS\\system32\\WindowsPowerShell\\v1.0\\powershell.exe', 
        "-Noninteractive {0} > {1}".format(temp_script_file, temp_output_file), temp_dir, 
        wait_for_end=wait_for_output) 

    output = None 
    if wait_for_output: 
     dl_url = file_manager.InitiateFileTransferFromGuest(vm, creds, 
                  temp_output_file) 
     logger.debug("DOWNLOAD OUTPUT FROM: " + dl_url.url) 
     r = requests.get(dl_url.url, verify=False) 
     output = r.text 
     logger.debug("Script Output was: %s", output) 

    logger.debug("DELETING temp files & directory") 
    file_manager.DeleteFileInGuest(vm, creds, temp_script_file) 
    file_manager.DeleteFileInGuest(vm, creds, temp_output_file) 
    file_manager.DeleteDirectoryInGuest(vm, creds, temp_dir, True) 
    logger.debug("Invoke-VMScript COMPLETE") 

    return output 

def remote_cmd(self, vm_name, vm_username, vm_password, command, args, working_dir, wait_for_end=False, timeout=60): 
    creds = vim.vm.guest.NamePasswordAuthentication(username=vm_username, password=vm_password) 
    vm = self.get_vm(vm_name) 
    try: 
     cmdspec = vim.vm.guest.ProcessManager.ProgramSpec(arguments=args, programPath=command) 
     pid = self.si.content.guestOperationsManager.processManager.StartProgramInGuest(vm=vm, auth=creds, 
                         spec=cmdspec) 
     logger.debug("Started process %d on %s", pid, vm_name) 
    except vmodl.MethodFault as error: 
     print("Caught vmodl fault : ", error.msg) 
     return -1 

    n = timeout 
    if wait_for_end: 
     while n > 0: 
      info = self.si.content.guestOperationsManager.processManager.ListProcessesInGuest(vm=vm, auth=creds, 
                           pids=[pid]) 
      if info[0].endTime is not None: 
       break 
      logger.debug("Process not yet completed. Will wait %d seconds", n) 
      sleep(1) 
      n = n - 1 
     logger.debug("Process completed with state: %s", info[0])