diff --git a/pkg/compute/guestdrivers/esxi.go b/pkg/compute/guestdrivers/esxi.go
index 3d04152c32..fbc5fc9778 100644
--- a/pkg/compute/guestdrivers/esxi.go
+++ b/pkg/compute/guestdrivers/esxi.go
@@ -3,7 +3,6 @@ package guestdrivers
 import (
 	"context"
 	"fmt"
-	"net/http"
 	"time"
 
 	"yunion.io/x/jsonutils"
@@ -13,6 +12,7 @@ import (
 	"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
 	"yunion.io/x/onecloud/pkg/compute/models"
 	"yunion.io/x/onecloud/pkg/util/billing"
+	"yunion.io/x/onecloud/pkg/util/httputils"
 )
 
 type SESXiGuestDriver struct {
@@ -101,11 +101,7 @@ func (self *SESXiGuestDriver) RequestDeployGuestOnHost(ctx context.Context, gues
 	config := guest.GetDeployConfigOnHost(ctx, host, task.GetParams())
 	log.Debugf("RequestDeployGuestOnHost: %s", config)
 
-	agent, err := host.GetEsxiAgentHost()
-	if err != nil {
-		return err
-	}
-	if agent == nil {
+	if !host.IsEsxiAgentReady() {
 		return fmt.Errorf("No ESXi agent host")
 	}
 
@@ -132,11 +128,9 @@ func (self *SESXiGuestDriver) RequestDeployGuestOnHost(ctx context.Context, gues
 	body := jsonutils.NewDict()
 	body.Add(config, "disk")
 
-	header := http.Header{}
-	header.Add("X-Task-Id", task.GetTaskId())
-	header.Add("X-Region-Version", "v2")
+	header := task.GetTaskRequestHeader()
 
-	_, err = agent.Request(ctx, task.GetUserCred(), "POST", url, header, body)
+	_, err = host.EsxiRequest(ctx, httputils.POST, url, header, body)
 	return err
 }
 
diff --git a/pkg/compute/hostdrivers/esxi.go b/pkg/compute/hostdrivers/esxi.go
index 84ff1c99c1..1374f7bde8 100644
--- a/pkg/compute/hostdrivers/esxi.go
+++ b/pkg/compute/hostdrivers/esxi.go
@@ -2,12 +2,12 @@ package hostdrivers
 
 import (
 	"context"
+	"errors"
 	"fmt"
 
 	"yunion.io/x/jsonutils"
 	"yunion.io/x/log"
 
-	"github.com/golang-plus/errors"
 	"yunion.io/x/onecloud/pkg/cloudcommon/db/taskman"
 	"yunion.io/x/onecloud/pkg/compute/models"
 	"yunion.io/x/onecloud/pkg/util/httputils"
@@ -61,7 +61,8 @@ func (self *SESXiHostDriver) CheckAndSetCacheImage(ctx context.Context, host *mo
 	content.ImageId = imageId
 	content.HostId = host.Id
 	content.HostIp = host.AccessIp
-	content.Format = cacheImage.GetFormat()
+	// format force VMDK
+	content.Format = "vmdk" // cacheImage.GetFormat()
 
 	storage := host.GetStorageByFilePath(storageCache.Path)
 	if storage == nil {
@@ -95,17 +96,11 @@ func (self *SESXiHostDriver) CheckAndSetCacheImage(ctx context.Context, host *mo
 		content.SrcDatastore = accessInfo
 	}
 
-	agent, err := host.GetEsxiAgentHost()
-	if err != nil {
-		log.Errorf("find ESXi agent fail: %s", err)
-		return err
-	}
-
-	if agent == nil {
+	if !host.IsEsxiAgentReady() {
 		return fmt.Errorf("fail to find valid ESXi agent")
 	}
 
-	url := fmt.Sprintf("%s/disks/image_cache", agent.ManagerUri)
+	url := "/disks/image_cache"
 
 	if isForce {
 		content.IsForce = true
@@ -117,7 +112,7 @@ func (self *SESXiHostDriver) CheckAndSetCacheImage(ctx context.Context, host *mo
 
 	header := task.GetTaskRequestHeader()
 
-	_, _, err = httputils.JSONRequest(httputils.GetDefaultClient(), ctx, "POST", url, header, body, false)
+	_, err = host.EsxiRequest(ctx, httputils.POST, url, header, body)
 	if err != nil {
 		return err
 	}
@@ -125,13 +120,7 @@ func (self *SESXiHostDriver) CheckAndSetCacheImage(ctx context.Context, host *mo
 }
 
 func (self *SESXiHostDriver) RequestAllocateDiskOnStorage(ctx context.Context, host *models.SHost, storage *models.SStorage, disk *models.SDisk, task taskman.ITask, content *jsonutils.JSONDict) error {
-	agent, err := host.GetEsxiAgentHost()
-	if err != nil {
-		log.Errorf("find ESXi agent fail: %s", err)
-		return err
-	}
-
-	if agent == nil {
+	if !host.IsEsxiAgentReady() {
 		return fmt.Errorf("fail to find valid ESXi agent")
 	}
 
@@ -158,18 +147,12 @@ func (self *SESXiHostDriver) RequestAllocateDiskOnStorage(ctx context.Context, h
 
 	header := task.GetTaskRequestHeader()
 
-	_, err = agent.Request(ctx, task.GetUserCred(), "POST", url, header, body)
+	_, err = host.EsxiRequest(ctx, httputils.POST, url, header, body)
 	return err
 }
 
 func (self *SESXiHostDriver) RequestPrepareSaveDiskOnHost(ctx context.Context, host *models.SHost, disk *models.SDisk, imageId string, task taskman.ITask) error {
-	agent, err := host.GetEsxiAgentHost()
-	if err != nil {
-		log.Errorf("find ESXi agent fail: %s", err)
-		return err
-	}
-
-	if agent == nil {
+	if !host.IsEsxiAgentReady() {
 		return fmt.Errorf("fail to find valid ESXi agent")
 	}
 
@@ -218,7 +201,7 @@ func (self *SESXiHostDriver) RequestPrepareSaveDiskOnHost(ctx context.Context, h
 	url := fmt.Sprintf("/disks/agent/save-prepare/%s", disk.Id)
 	header := task.GetTaskRequestHeader()
 
-	_, err = agent.Request(ctx, task.GetUserCred(), "POST", url, header, body)
+	_, err = host.EsxiRequest(ctx, httputils.POST, url, header, body)
 	return err
 }
 
@@ -228,15 +211,15 @@ func (self *SESXiHostDriver) RequestSaveUploadImageOnHost(ctx context.Context, h
 	if len(imagePath) == 0 {
 		return fmt.Errorf("missing parameter backup")
 	}
-	agentId, _ := data.GetString("agent_id")
-	if len(agentId) == 0 {
-		return fmt.Errorf("missing parameter agent_id")
-	}
+	// agentId, _ := data.GetString("agent_id")
+	// if len(agentId) == 0 {
+	// 	return fmt.Errorf("missing parameter agent_id")
+	// }
 
-	agent := models.HostManager.FetchHostById(agentId)
-	if agent == nil {
-		return fmt.Errorf("cannot find host with id %s", agentId)
-	}
+	// agent := models.HostManager.FetchHostById(agentId)
+	// if agent == nil {
+	// 	return fmt.Errorf("cannot find host with id %s", agentId)
+	// }
 
 	storage := disk.GetStorage()
 
@@ -262,6 +245,6 @@ func (self *SESXiHostDriver) RequestSaveUploadImageOnHost(ctx context.Context, h
 
 	header := task.GetTaskRequestHeader()
 
-	_, err := agent.Request(ctx, task.GetUserCred(), "POST", url, header, body)
+	_, err := host.EsxiRequest(ctx, httputils.POST, url, header, body)
 	return err
 }
diff --git a/pkg/compute/models/guests.go b/pkg/compute/models/guests.go
index c1ea6aacf0..ddc033e321 100644
--- a/pkg/compute/models/guests.go
+++ b/pkg/compute/models/guests.go
@@ -229,7 +229,7 @@ type SGuest struct {
 	SecgrpId      string `width:"36" charset:"ascii" nullable:"true" get:"user" create:"optional"` // Column(VARCHAR(36, charset='ascii'), nullable=True)
 	AdminSecgrpId string `width:"36" charset:"ascii" nullable:"true" get:"admin"`                  // Column(VARCHAR(36, charset='ascii'), nullable=True)
 
-	Hypervisor string `width:"16" charset:"ascii" nullable:"false" default:"kvm" list:"user"` // Column(VARCHAR(16, charset='ascii'), nullable=False, default=HYPERVISOR_DEFAULT)
+	Hypervisor string `width:"16" charset:"ascii" nullable:"false" default:"kvm" list:"user" create:"required"` // Column(VARCHAR(16, charset='ascii'), nullable=False, default=HYPERVISOR_DEFAULT)
 
 	InstanceType string `width:"64" charset:"ascii" nullable:"true" list:"user" create:"optional"`
 }
diff --git a/pkg/compute/models/hosts.go b/pkg/compute/models/hosts.go
index 4253341ac9..593ccf73ce 100644
--- a/pkg/compute/models/hosts.go
+++ b/pkg/compute/models/hosts.go
@@ -11,8 +11,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/serialx/hashring"
-
 	"yunion.io/x/jsonutils"
 	"yunion.io/x/log"
 	"yunion.io/x/pkg/tristate"
@@ -2216,16 +2214,6 @@ func (self *SHost) GetLocalStoragecache() *SStoragecache {
 	return nil
 }
 
-func (self *SHost) IsBaremetalAgentReady() bool {
-	url, err := auth.GetServiceURL("baremetal", options.Options.Region, self.GetZone().GetName(), "")
-	if err != nil {
-		log.Errorln("is baremetal agent ready: false")
-		return false
-	}
-	log.Infof("baremetal url:%s", url)
-	return true
-}
-
 func (self *SHost) PostCreate(ctx context.Context, userCred mcclient.TokenCredential, ownerProjId string, query jsonutils.JSONObject, data jsonutils.JSONObject) {
 	self.SEnabledStatusStandaloneResourceBase.PostCreate(ctx, userCred, ownerProjId, query, data)
 	kwargs := data.(*jsonutils.JSONDict)
@@ -2609,6 +2597,16 @@ func (self *SHost) StartBaremetalUnmaintenanceTask(ctx context.Context, userCred
 	return nil
 }
 
+func (self *SHost) IsBaremetalAgentReady() bool {
+	url, err := auth.GetServiceURL("baremetal", options.Options.Region, self.GetZone().GetName(), "")
+	if err != nil {
+		log.Errorln("is baremetal agent ready: false")
+		return false
+	}
+	log.Infof("baremetal url:%s", url)
+	return true
+}
+
 func (self *SHost) BaremetalSyncRequest(ctx context.Context, method httputils.THttpMethod, url string, headers http.Header, body *jsonutils.JSONDict) (jsonutils.JSONObject, error) {
 	serviceUrl, err := auth.GetServiceURL("baremetal", options.Options.Region, self.GetZone().GetName(), "")
 	if err != nil {
@@ -3506,43 +3504,63 @@ func (host *SHost) SyncHostExternalNics(ctx context.Context, userCred mcclient.T
 	return result
 }
 
-func (manager *SHostManager) GetEsxiAgentHostId(key string) (string, error) {
-	q := HostManager.Query("id")
-	q = q.Equals("host_status", HOST_ONLINE)
-	q = q.Equals("host_type", HOST_TYPE_HYPERVISOR)
-	q = q.IsTrue("enabled")
+// func (manager *SHostManager) GetEsxiAgentHostId(key string) (string, error) {
+// 	q := HostManager.Query("id")
+// 	q = q.Equals("host_status", HOST_ONLINE)
+// 	q = q.Equals("host_type", HOST_TYPE_HYPERVISOR)
+// 	q = q.IsTrue("enabled")
+//
+// 	rows, err := q.Rows()
+// 	if err != nil {
+// 		return "", err
+// 	}
+// 	defer rows.Close()
+//
+// 	var hostId string
+// 	hostIds := make([]string, 0)
+// 	for rows.Next() {
+// 		err = rows.Scan(&hostId)
+// 		if err != nil {
+// 			return "", err
+// 		}
+// 		hostIds = append(hostIds, hostId)
+// 	}
+//
+// 	ring := hashring.New(hostIds)
+// 	ret, _ := ring.GetNode(key)
+// 	return ret, nil
+// }
+//
+// func (manager *SHostManager) GetEsxiAgentHost(key string) (*SHost, error) {
+// 	hostId, err := manager.GetEsxiAgentHostId(key)
+// 	if err != nil {
+// 		return nil, err
+// 	}
+// 	return manager.FetchHostById(hostId), nil
+// }
+//
+// func (host *SHost) GetEsxiAgentHost() (*SHost, error) {
+// 	return HostManager.GetEsxiAgentHost(host.Id)
+// }
 
-	rows, err := q.Rows()
+func (self *SHost) IsEsxiAgentReady() bool {
+	url, err := auth.GetServiceURL("esxiagent", options.Options.Region, self.GetZone().GetName(), "")
 	if err != nil {
-		return "", err
+		log.Errorln("is esxi agent ready: false")
+		return false
 	}
-	defer rows.Close()
-
-	var hostId string
-	hostIds := make([]string, 0)
-	for rows.Next() {
-		err = rows.Scan(&hostId)
-		if err != nil {
-			return "", err
-		}
-		hostIds = append(hostIds, hostId)
-	}
-
-	ring := hashring.New(hostIds)
-	ret, _ := ring.GetNode(key)
-	return ret, nil
+	log.Infof("esxi agent url:%s", url)
+	return true
 }
 
-func (manager *SHostManager) GetEsxiAgentHost(key string) (*SHost, error) {
-	hostId, err := manager.GetEsxiAgentHostId(key)
+func (self *SHost) EsxiRequest(ctx context.Context, method httputils.THttpMethod, url string, headers http.Header, body *jsonutils.JSONDict) (jsonutils.JSONObject, error) {
+	serviceUrl, err := auth.GetServiceURL("esxiagent", options.Options.Region, self.GetZone().GetName(), "")
 	if err != nil {
 		return nil, err
 	}
-	return manager.FetchHostById(hostId), nil
-}
-
-func (host *SHost) GetEsxiAgentHost() (*SHost, error) {
-	return HostManager.GetEsxiAgentHost(host.Id)
+	url = serviceUrl + url
+	_, data, err := httputils.JSONRequest(httputils.GetDefaultClient(), ctx, method, url, headers, body, false)
+	return data, err
 }
 
 func (manager *SHostManager) GetHostByIp(hostIp string) (*SHost, error) {
diff --git a/pkg/mcclient/options/base.go b/pkg/mcclient/options/base.go
index d433d11165..e8a6d12c09 100644
--- a/pkg/mcclient/options/base.go
+++ b/pkg/mcclient/options/base.go
@@ -56,6 +56,9 @@ func optionsStructRvToParams(rv reflect.Value) (*jsonutils.JSONDict, error) {
 		if name == "" {
 			continue
 		}
+		if jsonInfo.Ignore {
+			continue
+		}
 		f := rv.Field(i)
 	begin:
 		switch f.Kind() {