diff --git a/cmd.pb.go b/cmd.pb.go
index 9b1911f..e9d92a5 100644
--- a/cmd.pb.go
+++ b/cmd.pb.go
@@ -468,6 +468,7 @@ type SaasReq struct {
 	//	*SaasReq_Read
 	//	*SaasReq_Write
 	//	*SaasReq_ColumnWrite
+	//	*SaasReq_ResetDs
 	//	*SaasReq_TaskCreate
 	//	*SaasReq_TaskList
 	//	*SaasReq_TaskRun
@@ -570,6 +571,15 @@ func (x *SaasReq) GetColumnWrite() *ColumnWrite {
 	return nil
 }
 
+func (x *SaasReq) GetResetDs() *ResetDs {
+	if x != nil {
+		if x, ok := x.Cmd.(*SaasReq_ResetDs); ok {
+			return x.ResetDs
+		}
+	}
+	return nil
+}
+
 func (x *SaasReq) GetTaskCreate() *Task {
 	if x != nil {
 		if x, ok := x.Cmd.(*SaasReq_TaskCreate); ok {
@@ -806,6 +816,10 @@ type SaasReq_ColumnWrite struct {
 	ColumnWrite *ColumnWrite `protobuf:"bytes,12,opt,name=column_write,json=columnWrite,proto3,oneof"` // 全量列式写入
 }
 
+type SaasReq_ResetDs struct {
+	ResetDs *ResetDs `protobuf:"bytes,13,opt,name=reset_ds,json=resetDs,proto3,oneof"` // 清空数据区
+}
+
 type SaasReq_TaskCreate struct {
 	TaskCreate *Task `protobuf:"bytes,20,opt,name=task_create,json=taskCreate,proto3,oneof"` // 任务创建
 }
@@ -910,6 +924,8 @@ func (*SaasReq_Write) isSaasReq_Cmd() {}
 
 func (*SaasReq_ColumnWrite) isSaasReq_Cmd() {}
 
+func (*SaasReq_ResetDs) isSaasReq_Cmd() {}
+
 func (*SaasReq_TaskCreate) isSaasReq_Cmd() {}
 
 func (*SaasReq_TaskList) isSaasReq_Cmd() {}
@@ -1180,7 +1196,7 @@ type WriteItem struct {
 	WriteUint32S *Uint32S `protobuf:"bytes,3,opt,name=write_uint32s,json=writeUint32s,proto3" json:"write_uint32s,omitempty"` // uint32区域。!!!弃用，请使用uint32s_kv
 	// Deprecated: Marked as deprecated in cmd.proto.
 	WriteFlagsWithExpire *FlagsWithExpire           `protobuf:"bytes,4,opt,name=write_flags_with_expire,json=writeFlagsWithExpire,proto3" json:"write_flags_with_expire,omitempty"`                                                                   // 标志位区域。!!!弃用，请使用flags_with_expire_kv
-	BytesKv              map[uint32]uint32          `protobuf:"bytes,5,rep,name=bytes_kv,json=bytesKv,proto3" json:"bytes_kv,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`                                  // 写入byte，key为1-64索引值，value为0-255数值。index/value超限会丢弃
+	BytesKv              map[uint32]uint32          `protobuf:"bytes,5,rep,name=bytes_kv,json=bytesKv,proto3" json:"bytes_kv,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`                                  // 写入uint8，key为1-64索引值，value为0-255数值。index/value超限会丢弃
 	Uint32SKv            map[uint32]uint32          `protobuf:"bytes,6,rep,name=uint32s_kv,json=uint32sKv,proto3" json:"uint32s_kv,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`                            // 写入uint32，key为1-8索引值，value为uint32数值。index超限会丢弃
 	FlagsWithExpireKv    map[uint32]*FlagWithExpire `protobuf:"bytes,7,rep,name=flags_with_expire_kv,json=flagsWithExpireKv,proto3" json:"flags_with_expire_kv,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` // 写入标志位，key为1-4索引值，index超限会丢弃
 	unknownFields        protoimpl.UnknownFields
@@ -1269,11 +1285,11 @@ func (x *WriteItem) GetFlagsWithExpireKv() map[uint32]*FlagWithExpire {
 	return nil
 }
 
-// Bytes 写入byte区域
+// Bytes 写入uint8区域
 type Bytes struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
-	Bytes         []byte                 `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`                  // 写入的byte
-	Index_1       uint64                 `protobuf:"varint,2,opt,name=index_1,json=index1,proto3" json:"index_1,omitempty"` // 写入byte的索引值(0..63)
+	Bytes         []byte                 `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`                  // 写入的uint8
+	Index_1       uint64                 `protobuf:"varint,2,opt,name=index_1,json=index1,proto3" json:"index_1,omitempty"` // 写入uint8的索引值(0..63)
 	unknownFields protoimpl.UnknownFields
 	sizeCache     protoimpl.SizeCache
 }
@@ -1566,6 +1582,51 @@ func (x *ColumnWrite) GetWriteFlagsWithExpire() *FlagsWithExpire {
 	return nil
 }
 
+// ResetDs 清空数据区命令
+type ResetDs struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	DataspaceId   string                 `protobuf:"bytes,1,opt,name=dataspace_id,json=dataspaceId,proto3" json:"dataspace_id,omitempty"` // 数据空间ID
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *ResetDs) Reset() {
+	*x = ResetDs{}
+	mi := &file_cmd_proto_msgTypes[11]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *ResetDs) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ResetDs) ProtoMessage() {}
+
+func (x *ResetDs) ProtoReflect() protoreflect.Message {
+	mi := &file_cmd_proto_msgTypes[11]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ResetDs.ProtoReflect.Descriptor instead.
+func (*ResetDs) Descriptor() ([]byte, []int) {
+	return file_cmd_proto_rawDescGZIP(), []int{11}
+}
+
+func (x *ResetDs) GetDataspaceId() string {
+	if x != nil {
+		return x.DataspaceId
+	}
+	return ""
+}
+
 type Task struct {
 	state           protoimpl.MessageState `protogen:"open.v1"`
 	DataspaceId     string                 `protobuf:"bytes,1,opt,name=dataspace_id,json=dataspaceId,proto3" json:"dataspace_id,omitempty"`             // 数据空间ID
@@ -1589,7 +1650,7 @@ type Task struct {
 
 func (x *Task) Reset() {
 	*x = Task{}
-	mi := &file_cmd_proto_msgTypes[11]
+	mi := &file_cmd_proto_msgTypes[12]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1601,7 +1662,7 @@ func (x *Task) String() string {
 func (*Task) ProtoMessage() {}
 
 func (x *Task) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[11]
+	mi := &file_cmd_proto_msgTypes[12]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1614,7 +1675,7 @@ func (x *Task) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use Task.ProtoReflect.Descriptor instead.
 func (*Task) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{11}
+	return file_cmd_proto_rawDescGZIP(), []int{12}
 }
 
 func (x *Task) GetDataspaceId() string {
@@ -1725,7 +1786,7 @@ type TaskList struct {
 
 func (x *TaskList) Reset() {
 	*x = TaskList{}
-	mi := &file_cmd_proto_msgTypes[12]
+	mi := &file_cmd_proto_msgTypes[13]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1737,7 +1798,7 @@ func (x *TaskList) String() string {
 func (*TaskList) ProtoMessage() {}
 
 func (x *TaskList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[12]
+	mi := &file_cmd_proto_msgTypes[13]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1750,7 +1811,7 @@ func (x *TaskList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TaskList.ProtoReflect.Descriptor instead.
 func (*TaskList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{12}
+	return file_cmd_proto_rawDescGZIP(), []int{13}
 }
 
 func (x *TaskList) GetStatusFilter() TaskStatus {
@@ -1770,7 +1831,7 @@ type TaskRun struct {
 
 func (x *TaskRun) Reset() {
 	*x = TaskRun{}
-	mi := &file_cmd_proto_msgTypes[13]
+	mi := &file_cmd_proto_msgTypes[14]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1782,7 +1843,7 @@ func (x *TaskRun) String() string {
 func (*TaskRun) ProtoMessage() {}
 
 func (x *TaskRun) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[13]
+	mi := &file_cmd_proto_msgTypes[14]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1795,7 +1856,7 @@ func (x *TaskRun) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TaskRun.ProtoReflect.Descriptor instead.
 func (*TaskRun) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{13}
+	return file_cmd_proto_rawDescGZIP(), []int{14}
 }
 
 func (x *TaskRun) GetTaskSha256() string {
@@ -1815,7 +1876,7 @@ type TaskDelete struct {
 
 func (x *TaskDelete) Reset() {
 	*x = TaskDelete{}
-	mi := &file_cmd_proto_msgTypes[14]
+	mi := &file_cmd_proto_msgTypes[15]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1827,7 +1888,7 @@ func (x *TaskDelete) String() string {
 func (*TaskDelete) ProtoMessage() {}
 
 func (x *TaskDelete) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[14]
+	mi := &file_cmd_proto_msgTypes[15]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1840,7 +1901,7 @@ func (x *TaskDelete) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TaskDelete.ProtoReflect.Descriptor instead.
 func (*TaskDelete) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{14}
+	return file_cmd_proto_rawDescGZIP(), []int{15}
 }
 
 func (x *TaskDelete) GetTaskSha256() string {
@@ -1860,7 +1921,7 @@ type TaskInfo struct {
 
 func (x *TaskInfo) Reset() {
 	*x = TaskInfo{}
-	mi := &file_cmd_proto_msgTypes[15]
+	mi := &file_cmd_proto_msgTypes[16]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1872,7 +1933,7 @@ func (x *TaskInfo) String() string {
 func (*TaskInfo) ProtoMessage() {}
 
 func (x *TaskInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[15]
+	mi := &file_cmd_proto_msgTypes[16]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1885,7 +1946,7 @@ func (x *TaskInfo) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.
 func (*TaskInfo) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{15}
+	return file_cmd_proto_rawDescGZIP(), []int{16}
 }
 
 func (x *TaskInfo) GetTaskSha256() string {
@@ -1907,7 +1968,7 @@ type FileInfo struct {
 
 func (x *FileInfo) Reset() {
 	*x = FileInfo{}
-	mi := &file_cmd_proto_msgTypes[16]
+	mi := &file_cmd_proto_msgTypes[17]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1919,7 +1980,7 @@ func (x *FileInfo) String() string {
 func (*FileInfo) ProtoMessage() {}
 
 func (x *FileInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[16]
+	mi := &file_cmd_proto_msgTypes[17]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1932,7 +1993,7 @@ func (x *FileInfo) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.
 func (*FileInfo) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{16}
+	return file_cmd_proto_rawDescGZIP(), []int{17}
 }
 
 func (x *FileInfo) GetFileName() string {
@@ -1968,7 +2029,7 @@ type FileBlock struct {
 
 func (x *FileBlock) Reset() {
 	*x = FileBlock{}
-	mi := &file_cmd_proto_msgTypes[17]
+	mi := &file_cmd_proto_msgTypes[18]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -1980,7 +2041,7 @@ func (x *FileBlock) String() string {
 func (*FileBlock) ProtoMessage() {}
 
 func (x *FileBlock) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[17]
+	mi := &file_cmd_proto_msgTypes[18]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1993,7 +2054,7 @@ func (x *FileBlock) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use FileBlock.ProtoReflect.Descriptor instead.
 func (*FileBlock) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{17}
+	return file_cmd_proto_rawDescGZIP(), []int{18}
 }
 
 func (x *FileBlock) GetBlockSha256() string {
@@ -2028,7 +2089,7 @@ type TargetList struct {
 
 func (x *TargetList) Reset() {
 	*x = TargetList{}
-	mi := &file_cmd_proto_msgTypes[18]
+	mi := &file_cmd_proto_msgTypes[19]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2040,7 +2101,7 @@ func (x *TargetList) String() string {
 func (*TargetList) ProtoMessage() {}
 
 func (x *TargetList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[18]
+	mi := &file_cmd_proto_msgTypes[19]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2053,7 +2114,7 @@ func (x *TargetList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetList.ProtoReflect.Descriptor instead.
 func (*TargetList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{18}
+	return file_cmd_proto_rawDescGZIP(), []int{19}
 }
 
 func (x *TargetList) GetTargets() []string {
@@ -2081,7 +2142,7 @@ type TargetCreate struct {
 
 func (x *TargetCreate) Reset() {
 	*x = TargetCreate{}
-	mi := &file_cmd_proto_msgTypes[19]
+	mi := &file_cmd_proto_msgTypes[20]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2093,7 +2154,7 @@ func (x *TargetCreate) String() string {
 func (*TargetCreate) ProtoMessage() {}
 
 func (x *TargetCreate) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[19]
+	mi := &file_cmd_proto_msgTypes[20]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2106,7 +2167,7 @@ func (x *TargetCreate) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetCreate.ProtoReflect.Descriptor instead.
 func (*TargetCreate) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{19}
+	return file_cmd_proto_rawDescGZIP(), []int{20}
 }
 
 func (x *TargetCreate) GetTargetId() string {
@@ -2133,7 +2194,7 @@ type TargetDelete struct {
 
 func (x *TargetDelete) Reset() {
 	*x = TargetDelete{}
-	mi := &file_cmd_proto_msgTypes[20]
+	mi := &file_cmd_proto_msgTypes[21]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2145,7 +2206,7 @@ func (x *TargetDelete) String() string {
 func (*TargetDelete) ProtoMessage() {}
 
 func (x *TargetDelete) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[20]
+	mi := &file_cmd_proto_msgTypes[21]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2158,7 +2219,7 @@ func (x *TargetDelete) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetDelete.ProtoReflect.Descriptor instead.
 func (*TargetDelete) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{20}
+	return file_cmd_proto_rawDescGZIP(), []int{21}
 }
 
 func (x *TargetDelete) GetTargetId() string {
@@ -2178,7 +2239,7 @@ type BindSet struct {
 
 func (x *BindSet) Reset() {
 	*x = BindSet{}
-	mi := &file_cmd_proto_msgTypes[21]
+	mi := &file_cmd_proto_msgTypes[22]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2190,7 +2251,7 @@ func (x *BindSet) String() string {
 func (*BindSet) ProtoMessage() {}
 
 func (x *BindSet) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[21]
+	mi := &file_cmd_proto_msgTypes[22]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2203,7 +2264,7 @@ func (x *BindSet) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use BindSet.ProtoReflect.Descriptor instead.
 func (*BindSet) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{21}
+	return file_cmd_proto_rawDescGZIP(), []int{22}
 }
 
 func (x *BindSet) GetBinds() []*Bind {
@@ -2223,7 +2284,7 @@ type BindDelete struct {
 
 func (x *BindDelete) Reset() {
 	*x = BindDelete{}
-	mi := &file_cmd_proto_msgTypes[22]
+	mi := &file_cmd_proto_msgTypes[23]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2235,7 +2296,7 @@ func (x *BindDelete) String() string {
 func (*BindDelete) ProtoMessage() {}
 
 func (x *BindDelete) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[22]
+	mi := &file_cmd_proto_msgTypes[23]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2248,7 +2309,7 @@ func (x *BindDelete) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use BindDelete.ProtoReflect.Descriptor instead.
 func (*BindDelete) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{22}
+	return file_cmd_proto_rawDescGZIP(), []int{23}
 }
 
 func (x *BindDelete) GetBinds() []*Bind {
@@ -2267,7 +2328,7 @@ type GrantList struct {
 
 func (x *GrantList) Reset() {
 	*x = GrantList{}
-	mi := &file_cmd_proto_msgTypes[23]
+	mi := &file_cmd_proto_msgTypes[24]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2279,7 +2340,7 @@ func (x *GrantList) String() string {
 func (*GrantList) ProtoMessage() {}
 
 func (x *GrantList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[23]
+	mi := &file_cmd_proto_msgTypes[24]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2292,7 +2353,7 @@ func (x *GrantList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use GrantList.ProtoReflect.Descriptor instead.
 func (*GrantList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{23}
+	return file_cmd_proto_rawDescGZIP(), []int{24}
 }
 
 // Grant 数据授权信息
@@ -2307,7 +2368,7 @@ type Grant struct {
 
 func (x *Grant) Reset() {
 	*x = Grant{}
-	mi := &file_cmd_proto_msgTypes[24]
+	mi := &file_cmd_proto_msgTypes[25]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2319,7 +2380,7 @@ func (x *Grant) String() string {
 func (*Grant) ProtoMessage() {}
 
 func (x *Grant) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[24]
+	mi := &file_cmd_proto_msgTypes[25]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2332,7 +2393,7 @@ func (x *Grant) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use Grant.ProtoReflect.Descriptor instead.
 func (*Grant) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{24}
+	return file_cmd_proto_rawDescGZIP(), []int{25}
 }
 
 func (x *Grant) GetTargetAccountId() uint32 {
@@ -2370,7 +2431,7 @@ type ScriptDebug struct {
 
 func (x *ScriptDebug) Reset() {
 	*x = ScriptDebug{}
-	mi := &file_cmd_proto_msgTypes[25]
+	mi := &file_cmd_proto_msgTypes[26]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2382,7 +2443,7 @@ func (x *ScriptDebug) String() string {
 func (*ScriptDebug) ProtoMessage() {}
 
 func (x *ScriptDebug) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[25]
+	mi := &file_cmd_proto_msgTypes[26]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2395,7 +2456,7 @@ func (x *ScriptDebug) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptDebug.ProtoReflect.Descriptor instead.
 func (*ScriptDebug) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{25}
+	return file_cmd_proto_rawDescGZIP(), []int{26}
 }
 
 func (x *ScriptDebug) GetLuaScript() string {
@@ -2444,7 +2505,7 @@ type ScriptCreate struct {
 
 func (x *ScriptCreate) Reset() {
 	*x = ScriptCreate{}
-	mi := &file_cmd_proto_msgTypes[26]
+	mi := &file_cmd_proto_msgTypes[27]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2456,7 +2517,7 @@ func (x *ScriptCreate) String() string {
 func (*ScriptCreate) ProtoMessage() {}
 
 func (x *ScriptCreate) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[26]
+	mi := &file_cmd_proto_msgTypes[27]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2469,7 +2530,7 @@ func (x *ScriptCreate) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptCreate.ProtoReflect.Descriptor instead.
 func (*ScriptCreate) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{26}
+	return file_cmd_proto_rawDescGZIP(), []int{27}
 }
 
 func (x *ScriptCreate) GetLuaName() string {
@@ -2495,7 +2556,7 @@ type ScriptList struct {
 
 func (x *ScriptList) Reset() {
 	*x = ScriptList{}
-	mi := &file_cmd_proto_msgTypes[27]
+	mi := &file_cmd_proto_msgTypes[28]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2507,7 +2568,7 @@ func (x *ScriptList) String() string {
 func (*ScriptList) ProtoMessage() {}
 
 func (x *ScriptList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[27]
+	mi := &file_cmd_proto_msgTypes[28]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2520,7 +2581,7 @@ func (x *ScriptList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptList.ProtoReflect.Descriptor instead.
 func (*ScriptList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{27}
+	return file_cmd_proto_rawDescGZIP(), []int{28}
 }
 
 // ScriptDelete 删除脚本
@@ -2533,7 +2594,7 @@ type ScriptDelete struct {
 
 func (x *ScriptDelete) Reset() {
 	*x = ScriptDelete{}
-	mi := &file_cmd_proto_msgTypes[28]
+	mi := &file_cmd_proto_msgTypes[29]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2545,7 +2606,7 @@ func (x *ScriptDelete) String() string {
 func (*ScriptDelete) ProtoMessage() {}
 
 func (x *ScriptDelete) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[28]
+	mi := &file_cmd_proto_msgTypes[29]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2558,7 +2619,7 @@ func (x *ScriptDelete) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptDelete.ProtoReflect.Descriptor instead.
 func (*ScriptDelete) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{28}
+	return file_cmd_proto_rawDescGZIP(), []int{29}
 }
 
 func (x *ScriptDelete) GetLuaName() string {
@@ -2578,7 +2639,7 @@ type ScriptGet struct {
 
 func (x *ScriptGet) Reset() {
 	*x = ScriptGet{}
-	mi := &file_cmd_proto_msgTypes[29]
+	mi := &file_cmd_proto_msgTypes[30]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2590,7 +2651,7 @@ func (x *ScriptGet) String() string {
 func (*ScriptGet) ProtoMessage() {}
 
 func (x *ScriptGet) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[29]
+	mi := &file_cmd_proto_msgTypes[30]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2603,7 +2664,7 @@ func (x *ScriptGet) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptGet.ProtoReflect.Descriptor instead.
 func (*ScriptGet) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{29}
+	return file_cmd_proto_rawDescGZIP(), []int{30}
 }
 
 func (x *ScriptGet) GetLuaName() string {
@@ -2623,7 +2684,7 @@ type ScriptUse struct {
 
 func (x *ScriptUse) Reset() {
 	*x = ScriptUse{}
-	mi := &file_cmd_proto_msgTypes[30]
+	mi := &file_cmd_proto_msgTypes[31]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2635,7 +2696,7 @@ func (x *ScriptUse) String() string {
 func (*ScriptUse) ProtoMessage() {}
 
 func (x *ScriptUse) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[30]
+	mi := &file_cmd_proto_msgTypes[31]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2648,7 +2709,7 @@ func (x *ScriptUse) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptUse.ProtoReflect.Descriptor instead.
 func (*ScriptUse) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{30}
+	return file_cmd_proto_rawDescGZIP(), []int{31}
 }
 
 func (x *ScriptUse) GetLuaName() string {
@@ -2667,7 +2728,7 @@ type ExpList struct {
 
 func (x *ExpList) Reset() {
 	*x = ExpList{}
-	mi := &file_cmd_proto_msgTypes[31]
+	mi := &file_cmd_proto_msgTypes[32]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2679,7 +2740,7 @@ func (x *ExpList) String() string {
 func (*ExpList) ProtoMessage() {}
 
 func (x *ExpList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[31]
+	mi := &file_cmd_proto_msgTypes[32]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2692,7 +2753,7 @@ func (x *ExpList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpList.ProtoReflect.Descriptor instead.
 func (*ExpList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{31}
+	return file_cmd_proto_rawDescGZIP(), []int{32}
 }
 
 // ExpGet 获取实验报表
@@ -2720,7 +2781,7 @@ type ExpGet struct {
 
 func (x *ExpGet) Reset() {
 	*x = ExpGet{}
-	mi := &file_cmd_proto_msgTypes[32]
+	mi := &file_cmd_proto_msgTypes[33]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2732,7 +2793,7 @@ func (x *ExpGet) String() string {
 func (*ExpGet) ProtoMessage() {}
 
 func (x *ExpGet) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[32]
+	mi := &file_cmd_proto_msgTypes[33]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2745,7 +2806,7 @@ func (x *ExpGet) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpGet.ProtoReflect.Descriptor instead.
 func (*ExpGet) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{32}
+	return file_cmd_proto_rawDescGZIP(), []int{33}
 }
 
 func (x *ExpGet) GetExtFields() []string {
@@ -2812,7 +2873,7 @@ type ExpGrantList struct {
 
 func (x *ExpGrantList) Reset() {
 	*x = ExpGrantList{}
-	mi := &file_cmd_proto_msgTypes[33]
+	mi := &file_cmd_proto_msgTypes[34]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2824,7 +2885,7 @@ func (x *ExpGrantList) String() string {
 func (*ExpGrantList) ProtoMessage() {}
 
 func (x *ExpGrantList) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[33]
+	mi := &file_cmd_proto_msgTypes[34]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2837,7 +2898,7 @@ func (x *ExpGrantList) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpGrantList.ProtoReflect.Descriptor instead.
 func (*ExpGrantList) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{33}
+	return file_cmd_proto_rawDescGZIP(), []int{34}
 }
 
 type ExpGrant struct {
@@ -2849,7 +2910,7 @@ type ExpGrant struct {
 
 func (x *ExpGrant) Reset() {
 	*x = ExpGrant{}
-	mi := &file_cmd_proto_msgTypes[34]
+	mi := &file_cmd_proto_msgTypes[35]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2861,7 +2922,7 @@ func (x *ExpGrant) String() string {
 func (*ExpGrant) ProtoMessage() {}
 
 func (x *ExpGrant) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[34]
+	mi := &file_cmd_proto_msgTypes[35]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2874,7 +2935,7 @@ func (x *ExpGrant) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpGrant.ProtoReflect.Descriptor instead.
 func (*ExpGrant) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{34}
+	return file_cmd_proto_rawDescGZIP(), []int{35}
 }
 
 func (x *ExpGrant) GetTargetAccountId() uint32 {
@@ -2894,6 +2955,7 @@ type SaasRes struct {
 	//	*SaasRes_InfoRes
 	//	*SaasRes_ReadRes
 	//	*SaasRes_WriteRes
+	//	*SaasRes_ResetDsRes
 	//	*SaasRes_TaskCreateRes
 	//	*SaasRes_TaskListRes
 	//	*SaasRes_TaskRunRes
@@ -2925,7 +2987,7 @@ type SaasRes struct {
 
 func (x *SaasRes) Reset() {
 	*x = SaasRes{}
-	mi := &file_cmd_proto_msgTypes[35]
+	mi := &file_cmd_proto_msgTypes[36]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -2937,7 +2999,7 @@ func (x *SaasRes) String() string {
 func (*SaasRes) ProtoMessage() {}
 
 func (x *SaasRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[35]
+	mi := &file_cmd_proto_msgTypes[36]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2950,7 +3012,7 @@ func (x *SaasRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use SaasRes.ProtoReflect.Descriptor instead.
 func (*SaasRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{35}
+	return file_cmd_proto_rawDescGZIP(), []int{36}
 }
 
 func (x *SaasRes) GetCode() ErrorCode {
@@ -3001,6 +3063,15 @@ func (x *SaasRes) GetWriteRes() *WriteRes {
 	return nil
 }
 
+func (x *SaasRes) GetResetDsRes() *ResetDsRes {
+	if x != nil {
+		if x, ok := x.Res.(*SaasRes_ResetDsRes); ok {
+			return x.ResetDsRes
+		}
+	}
+	return nil
+}
+
 func (x *SaasRes) GetTaskCreateRes() *Task {
 	if x != nil {
 		if x, ok := x.Res.(*SaasRes_TaskCreateRes); ok {
@@ -3233,6 +3304,10 @@ type SaasRes_WriteRes struct {
 	WriteRes *WriteRes `protobuf:"bytes,11,opt,name=write_res,json=writeRes,proto3,oneof"` // 写入命令返回
 }
 
+type SaasRes_ResetDsRes struct {
+	ResetDsRes *ResetDsRes `protobuf:"bytes,13,opt,name=reset_ds_res,json=resetDsRes,proto3,oneof"` // 清空数据区命令返回
+}
+
 type SaasRes_TaskCreateRes struct {
 	TaskCreateRes *Task `protobuf:"bytes,20,opt,name=task_create_res,json=taskCreateRes,proto3,oneof"` // 创建任务返回状态
 }
@@ -3335,6 +3410,8 @@ func (*SaasRes_ReadRes) isSaasRes_Res() {}
 
 func (*SaasRes_WriteRes) isSaasRes_Res() {}
 
+func (*SaasRes_ResetDsRes) isSaasRes_Res() {}
+
 func (*SaasRes_TaskCreateRes) isSaasRes_Res() {}
 
 func (*SaasRes_TaskListRes) isSaasRes_Res() {}
@@ -3396,7 +3473,7 @@ type DataSpace struct {
 
 func (x *DataSpace) Reset() {
 	*x = DataSpace{}
-	mi := &file_cmd_proto_msgTypes[36]
+	mi := &file_cmd_proto_msgTypes[37]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3408,7 +3485,7 @@ func (x *DataSpace) String() string {
 func (*DataSpace) ProtoMessage() {}
 
 func (x *DataSpace) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[36]
+	mi := &file_cmd_proto_msgTypes[37]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3421,7 +3498,7 @@ func (x *DataSpace) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use DataSpace.ProtoReflect.Descriptor instead.
 func (*DataSpace) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{36}
+	return file_cmd_proto_rawDescGZIP(), []int{37}
 }
 
 func (x *DataSpace) GetDid() []string {
@@ -3470,7 +3547,7 @@ type InfoRes struct {
 
 func (x *InfoRes) Reset() {
 	*x = InfoRes{}
-	mi := &file_cmd_proto_msgTypes[37]
+	mi := &file_cmd_proto_msgTypes[38]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3482,7 +3559,7 @@ func (x *InfoRes) String() string {
 func (*InfoRes) ProtoMessage() {}
 
 func (x *InfoRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[37]
+	mi := &file_cmd_proto_msgTypes[38]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3495,7 +3572,7 @@ func (x *InfoRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use InfoRes.ProtoReflect.Descriptor instead.
 func (*InfoRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{37}
+	return file_cmd_proto_rawDescGZIP(), []int{38}
 }
 
 func (x *InfoRes) GetDataspace() *DataSpace {
@@ -3524,7 +3601,7 @@ type ReadRes struct {
 
 func (x *ReadRes) Reset() {
 	*x = ReadRes{}
-	mi := &file_cmd_proto_msgTypes[38]
+	mi := &file_cmd_proto_msgTypes[39]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3536,7 +3613,7 @@ func (x *ReadRes) String() string {
 func (*ReadRes) ProtoMessage() {}
 
 func (x *ReadRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[38]
+	mi := &file_cmd_proto_msgTypes[39]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3549,7 +3626,7 @@ func (x *ReadRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ReadRes.ProtoReflect.Descriptor instead.
 func (*ReadRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{38}
+	return file_cmd_proto_rawDescGZIP(), []int{39}
 }
 
 func (x *ReadRes) GetSuccCmdCount() uint32 {
@@ -3585,7 +3662,7 @@ type WriteRes struct {
 
 func (x *WriteRes) Reset() {
 	*x = WriteRes{}
-	mi := &file_cmd_proto_msgTypes[39]
+	mi := &file_cmd_proto_msgTypes[40]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3597,7 +3674,7 @@ func (x *WriteRes) String() string {
 func (*WriteRes) ProtoMessage() {}
 
 func (x *WriteRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[39]
+	mi := &file_cmd_proto_msgTypes[40]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3610,7 +3687,7 @@ func (x *WriteRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use WriteRes.ProtoReflect.Descriptor instead.
 func (*WriteRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{39}
+	return file_cmd_proto_rawDescGZIP(), []int{40}
 }
 
 func (x *WriteRes) GetFailedUserid() []string {
@@ -3642,7 +3719,7 @@ type ValueItem struct {
 
 func (x *ValueItem) Reset() {
 	*x = ValueItem{}
-	mi := &file_cmd_proto_msgTypes[40]
+	mi := &file_cmd_proto_msgTypes[41]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3654,7 +3731,7 @@ func (x *ValueItem) String() string {
 func (*ValueItem) ProtoMessage() {}
 
 func (x *ValueItem) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[40]
+	mi := &file_cmd_proto_msgTypes[41]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3667,7 +3744,7 @@ func (x *ValueItem) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ValueItem.ProtoReflect.Descriptor instead.
 func (*ValueItem) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{40}
+	return file_cmd_proto_rawDescGZIP(), []int{41}
 }
 
 func (x *ValueItem) GetCmdIndex() uint32 {
@@ -3743,6 +3820,51 @@ func (x *ValueItem) GetFlagsWithExpireKv() map[uint32]*FlagWithExpire {
 	return nil
 }
 
+// ResetDsRes 清空数据区返回
+type ResetDsRes struct {
+	state         protoimpl.MessageState `protogen:"open.v1"`
+	DataspaceId   string                 `protobuf:"bytes,1,opt,name=dataspace_id,json=dataspaceId,proto3" json:"dataspace_id,omitempty"` // 数据空间ID
+	unknownFields protoimpl.UnknownFields
+	sizeCache     protoimpl.SizeCache
+}
+
+func (x *ResetDsRes) Reset() {
+	*x = ResetDsRes{}
+	mi := &file_cmd_proto_msgTypes[42]
+	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+	ms.StoreMessageInfo(mi)
+}
+
+func (x *ResetDsRes) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ResetDsRes) ProtoMessage() {}
+
+func (x *ResetDsRes) ProtoReflect() protoreflect.Message {
+	mi := &file_cmd_proto_msgTypes[42]
+	if x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ResetDsRes.ProtoReflect.Descriptor instead.
+func (*ResetDsRes) Descriptor() ([]byte, []int) {
+	return file_cmd_proto_rawDescGZIP(), []int{42}
+}
+
+func (x *ResetDsRes) GetDataspaceId() string {
+	if x != nil {
+		return x.DataspaceId
+	}
+	return ""
+}
+
 // TaskListRes 任务列表返回
 type TaskListRes struct {
 	state         protoimpl.MessageState `protogen:"open.v1"`
@@ -3753,7 +3875,7 @@ type TaskListRes struct {
 
 func (x *TaskListRes) Reset() {
 	*x = TaskListRes{}
-	mi := &file_cmd_proto_msgTypes[41]
+	mi := &file_cmd_proto_msgTypes[43]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3765,7 +3887,7 @@ func (x *TaskListRes) String() string {
 func (*TaskListRes) ProtoMessage() {}
 
 func (x *TaskListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[41]
+	mi := &file_cmd_proto_msgTypes[43]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3778,7 +3900,7 @@ func (x *TaskListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TaskListRes.ProtoReflect.Descriptor instead.
 func (*TaskListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{41}
+	return file_cmd_proto_rawDescGZIP(), []int{43}
 }
 
 func (x *TaskListRes) GetTasks() []*Task {
@@ -3798,7 +3920,7 @@ type TargetListRes struct {
 
 func (x *TargetListRes) Reset() {
 	*x = TargetListRes{}
-	mi := &file_cmd_proto_msgTypes[42]
+	mi := &file_cmd_proto_msgTypes[44]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3810,7 +3932,7 @@ func (x *TargetListRes) String() string {
 func (*TargetListRes) ProtoMessage() {}
 
 func (x *TargetListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[42]
+	mi := &file_cmd_proto_msgTypes[44]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3823,7 +3945,7 @@ func (x *TargetListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetListRes.ProtoReflect.Descriptor instead.
 func (*TargetListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{42}
+	return file_cmd_proto_rawDescGZIP(), []int{44}
 }
 
 func (x *TargetListRes) GetTargetList() map[string]*Binds {
@@ -3844,7 +3966,7 @@ type TargetCreateRes struct {
 
 func (x *TargetCreateRes) Reset() {
 	*x = TargetCreateRes{}
-	mi := &file_cmd_proto_msgTypes[43]
+	mi := &file_cmd_proto_msgTypes[45]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3856,7 +3978,7 @@ func (x *TargetCreateRes) String() string {
 func (*TargetCreateRes) ProtoMessage() {}
 
 func (x *TargetCreateRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[43]
+	mi := &file_cmd_proto_msgTypes[45]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3869,7 +3991,7 @@ func (x *TargetCreateRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetCreateRes.ProtoReflect.Descriptor instead.
 func (*TargetCreateRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{43}
+	return file_cmd_proto_rawDescGZIP(), []int{45}
 }
 
 func (x *TargetCreateRes) GetTargetId() string {
@@ -3897,7 +4019,7 @@ type TargetDeleteRes struct {
 
 func (x *TargetDeleteRes) Reset() {
 	*x = TargetDeleteRes{}
-	mi := &file_cmd_proto_msgTypes[44]
+	mi := &file_cmd_proto_msgTypes[46]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3909,7 +4031,7 @@ func (x *TargetDeleteRes) String() string {
 func (*TargetDeleteRes) ProtoMessage() {}
 
 func (x *TargetDeleteRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[44]
+	mi := &file_cmd_proto_msgTypes[46]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3922,7 +4044,7 @@ func (x *TargetDeleteRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TargetDeleteRes.ProtoReflect.Descriptor instead.
 func (*TargetDeleteRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{44}
+	return file_cmd_proto_rawDescGZIP(), []int{46}
 }
 
 func (x *TargetDeleteRes) GetTargetId() string {
@@ -3948,7 +4070,7 @@ type Binds struct {
 
 func (x *Binds) Reset() {
 	*x = Binds{}
-	mi := &file_cmd_proto_msgTypes[45]
+	mi := &file_cmd_proto_msgTypes[47]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -3960,7 +4082,7 @@ func (x *Binds) String() string {
 func (*Binds) ProtoMessage() {}
 
 func (x *Binds) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[45]
+	mi := &file_cmd_proto_msgTypes[47]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -3973,7 +4095,7 @@ func (x *Binds) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use Binds.ProtoReflect.Descriptor instead.
 func (*Binds) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{45}
+	return file_cmd_proto_rawDescGZIP(), []int{47}
 }
 
 func (x *Binds) GetBinds() []*Bind {
@@ -3997,7 +4119,7 @@ type Bind struct {
 
 func (x *Bind) Reset() {
 	*x = Bind{}
-	mi := &file_cmd_proto_msgTypes[46]
+	mi := &file_cmd_proto_msgTypes[48]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4009,7 +4131,7 @@ func (x *Bind) String() string {
 func (*Bind) ProtoMessage() {}
 
 func (x *Bind) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[46]
+	mi := &file_cmd_proto_msgTypes[48]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4022,7 +4144,7 @@ func (x *Bind) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use Bind.ProtoReflect.Descriptor instead.
 func (*Bind) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{46}
+	return file_cmd_proto_rawDescGZIP(), []int{48}
 }
 
 func (x *Bind) GetBindId() int64 {
@@ -4072,7 +4194,7 @@ type BindSetRes struct {
 
 func (x *BindSetRes) Reset() {
 	*x = BindSetRes{}
-	mi := &file_cmd_proto_msgTypes[47]
+	mi := &file_cmd_proto_msgTypes[49]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4084,7 +4206,7 @@ func (x *BindSetRes) String() string {
 func (*BindSetRes) ProtoMessage() {}
 
 func (x *BindSetRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[47]
+	mi := &file_cmd_proto_msgTypes[49]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4097,7 +4219,7 @@ func (x *BindSetRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use BindSetRes.ProtoReflect.Descriptor instead.
 func (*BindSetRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{47}
+	return file_cmd_proto_rawDescGZIP(), []int{49}
 }
 
 func (x *BindSetRes) GetSuccessNum() int32 {
@@ -4133,7 +4255,7 @@ type BindDeleteRes struct {
 
 func (x *BindDeleteRes) Reset() {
 	*x = BindDeleteRes{}
-	mi := &file_cmd_proto_msgTypes[48]
+	mi := &file_cmd_proto_msgTypes[50]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4145,7 +4267,7 @@ func (x *BindDeleteRes) String() string {
 func (*BindDeleteRes) ProtoMessage() {}
 
 func (x *BindDeleteRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[48]
+	mi := &file_cmd_proto_msgTypes[50]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4158,7 +4280,7 @@ func (x *BindDeleteRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use BindDeleteRes.ProtoReflect.Descriptor instead.
 func (*BindDeleteRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{48}
+	return file_cmd_proto_rawDescGZIP(), []int{50}
 }
 
 func (x *BindDeleteRes) GetSuccessNum() int32 {
@@ -4194,7 +4316,7 @@ type BindError struct {
 
 func (x *BindError) Reset() {
 	*x = BindError{}
-	mi := &file_cmd_proto_msgTypes[49]
+	mi := &file_cmd_proto_msgTypes[51]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4206,7 +4328,7 @@ func (x *BindError) String() string {
 func (*BindError) ProtoMessage() {}
 
 func (x *BindError) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[49]
+	mi := &file_cmd_proto_msgTypes[51]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4219,7 +4341,7 @@ func (x *BindError) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use BindError.ProtoReflect.Descriptor instead.
 func (*BindError) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{49}
+	return file_cmd_proto_rawDescGZIP(), []int{51}
 }
 
 func (x *BindError) GetBindId() int64 {
@@ -4254,7 +4376,7 @@ type GrantListRes struct {
 
 func (x *GrantListRes) Reset() {
 	*x = GrantListRes{}
-	mi := &file_cmd_proto_msgTypes[50]
+	mi := &file_cmd_proto_msgTypes[52]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4266,7 +4388,7 @@ func (x *GrantListRes) String() string {
 func (*GrantListRes) ProtoMessage() {}
 
 func (x *GrantListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[50]
+	mi := &file_cmd_proto_msgTypes[52]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4279,7 +4401,7 @@ func (x *GrantListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use GrantListRes.ProtoReflect.Descriptor instead.
 func (*GrantListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{50}
+	return file_cmd_proto_rawDescGZIP(), []int{52}
 }
 
 func (x *GrantListRes) GetFrom() []*Grant {
@@ -4309,7 +4431,7 @@ type ScriptDebugRes struct {
 
 func (x *ScriptDebugRes) Reset() {
 	*x = ScriptDebugRes{}
-	mi := &file_cmd_proto_msgTypes[51]
+	mi := &file_cmd_proto_msgTypes[53]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4321,7 +4443,7 @@ func (x *ScriptDebugRes) String() string {
 func (*ScriptDebugRes) ProtoMessage() {}
 
 func (x *ScriptDebugRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[51]
+	mi := &file_cmd_proto_msgTypes[53]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4334,7 +4456,7 @@ func (x *ScriptDebugRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptDebugRes.ProtoReflect.Descriptor instead.
 func (*ScriptDebugRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{51}
+	return file_cmd_proto_rawDescGZIP(), []int{53}
 }
 
 func (x *ScriptDebugRes) GetPrintOutput() string {
@@ -4377,7 +4499,7 @@ type ScriptInfo struct {
 
 func (x *ScriptInfo) Reset() {
 	*x = ScriptInfo{}
-	mi := &file_cmd_proto_msgTypes[52]
+	mi := &file_cmd_proto_msgTypes[54]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4389,7 +4511,7 @@ func (x *ScriptInfo) String() string {
 func (*ScriptInfo) ProtoMessage() {}
 
 func (x *ScriptInfo) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[52]
+	mi := &file_cmd_proto_msgTypes[54]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4402,7 +4524,7 @@ func (x *ScriptInfo) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptInfo.ProtoReflect.Descriptor instead.
 func (*ScriptInfo) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{52}
+	return file_cmd_proto_rawDescGZIP(), []int{54}
 }
 
 func (x *ScriptInfo) GetLuaName() string {
@@ -4443,7 +4565,7 @@ type ScriptCreateRes struct {
 
 func (x *ScriptCreateRes) Reset() {
 	*x = ScriptCreateRes{}
-	mi := &file_cmd_proto_msgTypes[53]
+	mi := &file_cmd_proto_msgTypes[55]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4455,7 +4577,7 @@ func (x *ScriptCreateRes) String() string {
 func (*ScriptCreateRes) ProtoMessage() {}
 
 func (x *ScriptCreateRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[53]
+	mi := &file_cmd_proto_msgTypes[55]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4468,7 +4590,7 @@ func (x *ScriptCreateRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptCreateRes.ProtoReflect.Descriptor instead.
 func (*ScriptCreateRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{53}
+	return file_cmd_proto_rawDescGZIP(), []int{55}
 }
 
 func (x *ScriptCreateRes) GetScriptInfo() *ScriptInfo {
@@ -4488,7 +4610,7 @@ type ScriptListRes struct {
 
 func (x *ScriptListRes) Reset() {
 	*x = ScriptListRes{}
-	mi := &file_cmd_proto_msgTypes[54]
+	mi := &file_cmd_proto_msgTypes[56]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4500,7 +4622,7 @@ func (x *ScriptListRes) String() string {
 func (*ScriptListRes) ProtoMessage() {}
 
 func (x *ScriptListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[54]
+	mi := &file_cmd_proto_msgTypes[56]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4513,7 +4635,7 @@ func (x *ScriptListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptListRes.ProtoReflect.Descriptor instead.
 func (*ScriptListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{54}
+	return file_cmd_proto_rawDescGZIP(), []int{56}
 }
 
 func (x *ScriptListRes) GetScriptInfo() []*ScriptInfo {
@@ -4533,7 +4655,7 @@ type ScriptGetRes struct {
 
 func (x *ScriptGetRes) Reset() {
 	*x = ScriptGetRes{}
-	mi := &file_cmd_proto_msgTypes[55]
+	mi := &file_cmd_proto_msgTypes[57]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4545,7 +4667,7 @@ func (x *ScriptGetRes) String() string {
 func (*ScriptGetRes) ProtoMessage() {}
 
 func (x *ScriptGetRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[55]
+	mi := &file_cmd_proto_msgTypes[57]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4558,7 +4680,7 @@ func (x *ScriptGetRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptGetRes.ProtoReflect.Descriptor instead.
 func (*ScriptGetRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{55}
+	return file_cmd_proto_rawDescGZIP(), []int{57}
 }
 
 func (x *ScriptGetRes) GetScriptInfo() *ScriptInfo {
@@ -4578,7 +4700,7 @@ type ScriptDeleteRes struct {
 
 func (x *ScriptDeleteRes) Reset() {
 	*x = ScriptDeleteRes{}
-	mi := &file_cmd_proto_msgTypes[56]
+	mi := &file_cmd_proto_msgTypes[58]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4590,7 +4712,7 @@ func (x *ScriptDeleteRes) String() string {
 func (*ScriptDeleteRes) ProtoMessage() {}
 
 func (x *ScriptDeleteRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[56]
+	mi := &file_cmd_proto_msgTypes[58]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4603,7 +4725,7 @@ func (x *ScriptDeleteRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptDeleteRes.ProtoReflect.Descriptor instead.
 func (*ScriptDeleteRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{56}
+	return file_cmd_proto_rawDescGZIP(), []int{58}
 }
 
 func (x *ScriptDeleteRes) GetScriptInfo() *ScriptInfo {
@@ -4623,7 +4745,7 @@ type ScriptUseRes struct {
 
 func (x *ScriptUseRes) Reset() {
 	*x = ScriptUseRes{}
-	mi := &file_cmd_proto_msgTypes[57]
+	mi := &file_cmd_proto_msgTypes[59]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4635,7 +4757,7 @@ func (x *ScriptUseRes) String() string {
 func (*ScriptUseRes) ProtoMessage() {}
 
 func (x *ScriptUseRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[57]
+	mi := &file_cmd_proto_msgTypes[59]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4648,7 +4770,7 @@ func (x *ScriptUseRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ScriptUseRes.ProtoReflect.Descriptor instead.
 func (*ScriptUseRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{57}
+	return file_cmd_proto_rawDescGZIP(), []int{59}
 }
 
 func (x *ScriptUseRes) GetScriptInfo() *ScriptInfo {
@@ -4668,7 +4790,7 @@ type ExpListRes struct {
 
 func (x *ExpListRes) Reset() {
 	*x = ExpListRes{}
-	mi := &file_cmd_proto_msgTypes[58]
+	mi := &file_cmd_proto_msgTypes[60]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4680,7 +4802,7 @@ func (x *ExpListRes) String() string {
 func (*ExpListRes) ProtoMessage() {}
 
 func (x *ExpListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[58]
+	mi := &file_cmd_proto_msgTypes[60]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4693,7 +4815,7 @@ func (x *ExpListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpListRes.ProtoReflect.Descriptor instead.
 func (*ExpListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{58}
+	return file_cmd_proto_rawDescGZIP(), []int{60}
 }
 
 func (x *ExpListRes) GetBuckets() []*ExpBucket {
@@ -4714,7 +4836,7 @@ type ExpBucket struct {
 
 func (x *ExpBucket) Reset() {
 	*x = ExpBucket{}
-	mi := &file_cmd_proto_msgTypes[59]
+	mi := &file_cmd_proto_msgTypes[61]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4726,7 +4848,7 @@ func (x *ExpBucket) String() string {
 func (*ExpBucket) ProtoMessage() {}
 
 func (x *ExpBucket) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[59]
+	mi := &file_cmd_proto_msgTypes[61]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4739,7 +4861,7 @@ func (x *ExpBucket) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpBucket.ProtoReflect.Descriptor instead.
 func (*ExpBucket) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{59}
+	return file_cmd_proto_rawDescGZIP(), []int{61}
 }
 
 func (x *ExpBucket) GetBucketId() uint32 {
@@ -4773,7 +4895,7 @@ type ExpGetRes struct {
 
 func (x *ExpGetRes) Reset() {
 	*x = ExpGetRes{}
-	mi := &file_cmd_proto_msgTypes[60]
+	mi := &file_cmd_proto_msgTypes[62]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4785,7 +4907,7 @@ func (x *ExpGetRes) String() string {
 func (*ExpGetRes) ProtoMessage() {}
 
 func (x *ExpGetRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[60]
+	mi := &file_cmd_proto_msgTypes[62]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4798,7 +4920,7 @@ func (x *ExpGetRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpGetRes.ProtoReflect.Descriptor instead.
 func (*ExpGetRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{60}
+	return file_cmd_proto_rawDescGZIP(), []int{62}
 }
 
 func (x *ExpGetRes) GetExpData() []*ExpData {
@@ -4822,7 +4944,7 @@ type ExpData struct {
 
 func (x *ExpData) Reset() {
 	*x = ExpData{}
-	mi := &file_cmd_proto_msgTypes[61]
+	mi := &file_cmd_proto_msgTypes[63]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4834,7 +4956,7 @@ func (x *ExpData) String() string {
 func (*ExpData) ProtoMessage() {}
 
 func (x *ExpData) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[61]
+	mi := &file_cmd_proto_msgTypes[63]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4847,7 +4969,7 @@ func (x *ExpData) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpData.ProtoReflect.Descriptor instead.
 func (*ExpData) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{61}
+	return file_cmd_proto_rawDescGZIP(), []int{63}
 }
 
 func (x *ExpData) GetTime() uint64 {
@@ -4905,7 +5027,7 @@ type ExpBaseFields struct {
 
 func (x *ExpBaseFields) Reset() {
 	*x = ExpBaseFields{}
-	mi := &file_cmd_proto_msgTypes[62]
+	mi := &file_cmd_proto_msgTypes[64]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -4917,7 +5039,7 @@ func (x *ExpBaseFields) String() string {
 func (*ExpBaseFields) ProtoMessage() {}
 
 func (x *ExpBaseFields) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[62]
+	mi := &file_cmd_proto_msgTypes[64]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -4930,7 +5052,7 @@ func (x *ExpBaseFields) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpBaseFields.ProtoReflect.Descriptor instead.
 func (*ExpBaseFields) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{62}
+	return file_cmd_proto_rawDescGZIP(), []int{64}
 }
 
 func (x *ExpBaseFields) GetCost() float64 {
@@ -5021,7 +5143,7 @@ type ExpGrantListRes struct {
 
 func (x *ExpGrantListRes) Reset() {
 	*x = ExpGrantListRes{}
-	mi := &file_cmd_proto_msgTypes[63]
+	mi := &file_cmd_proto_msgTypes[65]
 	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 	ms.StoreMessageInfo(mi)
 }
@@ -5033,7 +5155,7 @@ func (x *ExpGrantListRes) String() string {
 func (*ExpGrantListRes) ProtoMessage() {}
 
 func (x *ExpGrantListRes) ProtoReflect() protoreflect.Message {
-	mi := &file_cmd_proto_msgTypes[63]
+	mi := &file_cmd_proto_msgTypes[65]
 	if x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -5046,7 +5168,7 @@ func (x *ExpGrantListRes) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ExpGrantListRes.ProtoReflect.Descriptor instead.
 func (*ExpGrantListRes) Descriptor() ([]byte, []int) {
-	return file_cmd_proto_rawDescGZIP(), []int{63}
+	return file_cmd_proto_rawDescGZIP(), []int{65}
 }
 
 func (x *ExpGrantListRes) GetFrom() []*ExpGrant {
@@ -5067,13 +5189,14 @@ var File_cmd_proto protoreflect.FileDescriptor
 
 const file_cmd_proto_rawDesc = "" +
 	"\n" +
-	"\tcmd.proto\x12\asaasapi\"\xd9\v\n" +
+	"\tcmd.proto\x12\asaasapi\"\x88\f\n" +
 	"\aSaasReq\x12#\n" +
 	"\x04info\x18\x05 \x01(\v2\r.saasapi.InfoH\x00R\x04info\x12#\n" +
 	"\x04read\x18\n" +
 	" \x01(\v2\r.saasapi.ReadH\x00R\x04read\x12&\n" +
 	"\x05write\x18\v \x01(\v2\x0e.saasapi.WriteH\x00R\x05write\x129\n" +
-	"\fcolumn_write\x18\f \x01(\v2\x14.saasapi.ColumnWriteH\x00R\vcolumnWrite\x120\n" +
+	"\fcolumn_write\x18\f \x01(\v2\x14.saasapi.ColumnWriteH\x00R\vcolumnWrite\x12-\n" +
+	"\breset_ds\x18\r \x01(\v2\x10.saasapi.ResetDsH\x00R\aresetDs\x120\n" +
 	"\vtask_create\x18\x14 \x01(\v2\r.saasapi.TaskH\x00R\n" +
 	"taskCreate\x120\n" +
 	"\ttask_list\x18\x15 \x01(\v2\x11.saasapi.TaskListH\x00R\btaskList\x12-\n" +
@@ -5159,7 +5282,9 @@ const file_cmd_proto_rawDesc = "" +
 	"\vwrite_bytes\x18\x03 \x01(\v2\x0e.saasapi.BytesR\n" +
 	"writeBytes\x125\n" +
 	"\rwrite_uint32s\x18\x04 \x01(\v2\x10.saasapi.Uint32sR\fwriteUint32s\x12O\n" +
-	"\x17write_flags_with_expire\x18\x05 \x01(\v2\x18.saasapi.FlagsWithExpireR\x14writeFlagsWithExpire\"\xfc\x03\n" +
+	"\x17write_flags_with_expire\x18\x05 \x01(\v2\x18.saasapi.FlagsWithExpireR\x14writeFlagsWithExpire\",\n" +
+	"\aResetDs\x12!\n" +
+	"\fdataspace_id\x18\x01 \x01(\tR\vdataspaceId\"\xfc\x03\n" +
 	"\x04Task\x12!\n" +
 	"\fdataspace_id\x18\x01 \x01(\tR\vdataspaceId\x12\x14\n" +
 	"\x05appid\x18\x02 \x01(\tR\x05appid\x12\x1f\n" +
@@ -5257,7 +5382,7 @@ const file_cmd_proto_rawDesc = "" +
 	"total_flag\x18\x1e \x01(\rR\ttotalFlag\"\x0e\n" +
 	"\fExpGrantList\"6\n" +
 	"\bExpGrant\x12*\n" +
-	"\x11target_account_id\x18\x01 \x01(\rR\x0ftargetAccountId\"\xc7\r\n" +
+	"\x11target_account_id\x18\x01 \x01(\rR\x0ftargetAccountId\"\x80\x0e\n" +
 	"\aSaasRes\x12&\n" +
 	"\x04code\x18\x01 \x01(\x0e2\x12.saasapi.ErrorCodeR\x04code\x12\x16\n" +
 	"\x06status\x18\x02 \x01(\tR\x06status\x12-\n" +
@@ -5265,6 +5390,8 @@ const file_cmd_proto_rawDesc = "" +
 	"\bread_res\x18\n" +
 	" \x01(\v2\x10.saasapi.ReadResH\x00R\areadRes\x120\n" +
 	"\twrite_res\x18\v \x01(\v2\x11.saasapi.WriteResH\x00R\bwriteRes\x127\n" +
+	"\freset_ds_res\x18\r \x01(\v2\x13.saasapi.ResetDsResH\x00R\n" +
+	"resetDsRes\x127\n" +
 	"\x0ftask_create_res\x18\x14 \x01(\v2\r.saasapi.TaskH\x00R\rtaskCreateRes\x12:\n" +
 	"\rtask_list_res\x18\x15 \x01(\v2\x14.saasapi.TaskListResH\x00R\vtaskListRes\x121\n" +
 	"\ftask_run_res\x18\x16 \x01(\v2\r.saasapi.TaskH\x00R\n" +
@@ -5329,7 +5456,10 @@ const file_cmd_proto_rawDesc = "" +
 	"\x05value\x18\x02 \x01(\rR\x05value:\x028\x01\x1a]\n" +
 	"\x16FlagsWithExpireKvEntry\x12\x10\n" +
 	"\x03key\x18\x01 \x01(\rR\x03key\x12-\n" +
-	"\x05value\x18\x02 \x01(\v2\x17.saasapi.FlagWithExpireR\x05value:\x028\x01\"2\n" +
+	"\x05value\x18\x02 \x01(\v2\x17.saasapi.FlagWithExpireR\x05value:\x028\x01\"/\n" +
+	"\n" +
+	"ResetDsRes\x12!\n" +
+	"\fdataspace_id\x18\x01 \x01(\tR\vdataspaceId\"2\n" +
 	"\vTaskListRes\x12#\n" +
 	"\x05tasks\x18\x01 \x03(\v2\r.saasapi.TaskR\x05tasks\"\xa7\x01\n" +
 	"\rTargetListRes\x12G\n" +
@@ -5521,7 +5651,7 @@ func file_cmd_proto_rawDescGZIP() []byte {
 }
 
 var file_cmd_proto_enumTypes = make([]protoimpl.EnumInfo, 7)
-var file_cmd_proto_msgTypes = make([]protoimpl.MessageInfo, 73)
+var file_cmd_proto_msgTypes = make([]protoimpl.MessageInfo, 75)
 var file_cmd_proto_goTypes = []any{
 	(BindType)(0),           // 0: saasapi.BindType
 	(BindSourceType)(0),     // 1: saasapi.BindSourceType
@@ -5541,181 +5671,185 @@ var file_cmd_proto_goTypes = []any{
 	(*FlagsWithExpire)(nil), // 15: saasapi.FlagsWithExpire
 	(*FlagWithExpire)(nil),  // 16: saasapi.FlagWithExpire
 	(*ColumnWrite)(nil),     // 17: saasapi.ColumnWrite
-	(*Task)(nil),            // 18: saasapi.Task
-	(*TaskList)(nil),        // 19: saasapi.TaskList
-	(*TaskRun)(nil),         // 20: saasapi.TaskRun
-	(*TaskDelete)(nil),      // 21: saasapi.TaskDelete
-	(*TaskInfo)(nil),        // 22: saasapi.TaskInfo
-	(*FileInfo)(nil),        // 23: saasapi.FileInfo
-	(*FileBlock)(nil),       // 24: saasapi.FileBlock
-	(*TargetList)(nil),      // 25: saasapi.TargetList
-	(*TargetCreate)(nil),    // 26: saasapi.TargetCreate
-	(*TargetDelete)(nil),    // 27: saasapi.TargetDelete
-	(*BindSet)(nil),         // 28: saasapi.BindSet
-	(*BindDelete)(nil),      // 29: saasapi.BindDelete
-	(*GrantList)(nil),       // 30: saasapi.GrantList
-	(*Grant)(nil),           // 31: saasapi.Grant
-	(*ScriptDebug)(nil),     // 32: saasapi.ScriptDebug
-	(*ScriptCreate)(nil),    // 33: saasapi.ScriptCreate
-	(*ScriptList)(nil),      // 34: saasapi.ScriptList
-	(*ScriptDelete)(nil),    // 35: saasapi.ScriptDelete
-	(*ScriptGet)(nil),       // 36: saasapi.ScriptGet
-	(*ScriptUse)(nil),       // 37: saasapi.ScriptUse
-	(*ExpList)(nil),         // 38: saasapi.ExpList
-	(*ExpGet)(nil),          // 39: saasapi.ExpGet
-	(*ExpGrantList)(nil),    // 40: saasapi.ExpGrantList
-	(*ExpGrant)(nil),        // 41: saasapi.ExpGrant
-	(*SaasRes)(nil),         // 42: saasapi.SaasRes
-	(*DataSpace)(nil),       // 43: saasapi.DataSpace
-	(*InfoRes)(nil),         // 44: saasapi.InfoRes
-	(*ReadRes)(nil),         // 45: saasapi.ReadRes
-	(*WriteRes)(nil),        // 46: saasapi.WriteRes
-	(*ValueItem)(nil),       // 47: saasapi.ValueItem
-	(*TaskListRes)(nil),     // 48: saasapi.TaskListRes
-	(*TargetListRes)(nil),   // 49: saasapi.TargetListRes
-	(*TargetCreateRes)(nil), // 50: saasapi.TargetCreateRes
-	(*TargetDeleteRes)(nil), // 51: saasapi.TargetDeleteRes
-	(*Binds)(nil),           // 52: saasapi.Binds
-	(*Bind)(nil),            // 53: saasapi.Bind
-	(*BindSetRes)(nil),      // 54: saasapi.BindSetRes
-	(*BindDeleteRes)(nil),   // 55: saasapi.BindDeleteRes
-	(*BindError)(nil),       // 56: saasapi.BindError
-	(*GrantListRes)(nil),    // 57: saasapi.GrantListRes
-	(*ScriptDebugRes)(nil),  // 58: saasapi.ScriptDebugRes
-	(*ScriptInfo)(nil),      // 59: saasapi.ScriptInfo
-	(*ScriptCreateRes)(nil), // 60: saasapi.ScriptCreateRes
-	(*ScriptListRes)(nil),   // 61: saasapi.ScriptListRes
-	(*ScriptGetRes)(nil),    // 62: saasapi.ScriptGetRes
-	(*ScriptDeleteRes)(nil), // 63: saasapi.ScriptDeleteRes
-	(*ScriptUseRes)(nil),    // 64: saasapi.ScriptUseRes
-	(*ExpListRes)(nil),      // 65: saasapi.ExpListRes
-	(*ExpBucket)(nil),       // 66: saasapi.ExpBucket
-	(*ExpGetRes)(nil),       // 67: saasapi.ExpGetRes
-	(*ExpData)(nil),         // 68: saasapi.ExpData
-	(*ExpBaseFields)(nil),   // 69: saasapi.ExpBaseFields
-	(*ExpGrantListRes)(nil), // 70: saasapi.ExpGrantListRes
-	nil,                     // 71: saasapi.WriteItem.BytesKvEntry
-	nil,                     // 72: saasapi.WriteItem.Uint32sKvEntry
-	nil,                     // 73: saasapi.WriteItem.FlagsWithExpireKvEntry
-	nil,                     // 74: saasapi.ValueItem.BytesKvEntry
-	nil,                     // 75: saasapi.ValueItem.Uint32sKvEntry
-	nil,                     // 76: saasapi.ValueItem.FlagsWithExpireKvEntry
-	nil,                     // 77: saasapi.TargetListRes.TargetListEntry
-	nil,                     // 78: saasapi.ExpData.ExtFieldsEntry
-	nil,                     // 79: saasapi.ExpData.GroupEntry
+	(*ResetDs)(nil),         // 18: saasapi.ResetDs
+	(*Task)(nil),            // 19: saasapi.Task
+	(*TaskList)(nil),        // 20: saasapi.TaskList
+	(*TaskRun)(nil),         // 21: saasapi.TaskRun
+	(*TaskDelete)(nil),      // 22: saasapi.TaskDelete
+	(*TaskInfo)(nil),        // 23: saasapi.TaskInfo
+	(*FileInfo)(nil),        // 24: saasapi.FileInfo
+	(*FileBlock)(nil),       // 25: saasapi.FileBlock
+	(*TargetList)(nil),      // 26: saasapi.TargetList
+	(*TargetCreate)(nil),    // 27: saasapi.TargetCreate
+	(*TargetDelete)(nil),    // 28: saasapi.TargetDelete
+	(*BindSet)(nil),         // 29: saasapi.BindSet
+	(*BindDelete)(nil),      // 30: saasapi.BindDelete
+	(*GrantList)(nil),       // 31: saasapi.GrantList
+	(*Grant)(nil),           // 32: saasapi.Grant
+	(*ScriptDebug)(nil),     // 33: saasapi.ScriptDebug
+	(*ScriptCreate)(nil),    // 34: saasapi.ScriptCreate
+	(*ScriptList)(nil),      // 35: saasapi.ScriptList
+	(*ScriptDelete)(nil),    // 36: saasapi.ScriptDelete
+	(*ScriptGet)(nil),       // 37: saasapi.ScriptGet
+	(*ScriptUse)(nil),       // 38: saasapi.ScriptUse
+	(*ExpList)(nil),         // 39: saasapi.ExpList
+	(*ExpGet)(nil),          // 40: saasapi.ExpGet
+	(*ExpGrantList)(nil),    // 41: saasapi.ExpGrantList
+	(*ExpGrant)(nil),        // 42: saasapi.ExpGrant
+	(*SaasRes)(nil),         // 43: saasapi.SaasRes
+	(*DataSpace)(nil),       // 44: saasapi.DataSpace
+	(*InfoRes)(nil),         // 45: saasapi.InfoRes
+	(*ReadRes)(nil),         // 46: saasapi.ReadRes
+	(*WriteRes)(nil),        // 47: saasapi.WriteRes
+	(*ValueItem)(nil),       // 48: saasapi.ValueItem
+	(*ResetDsRes)(nil),      // 49: saasapi.ResetDsRes
+	(*TaskListRes)(nil),     // 50: saasapi.TaskListRes
+	(*TargetListRes)(nil),   // 51: saasapi.TargetListRes
+	(*TargetCreateRes)(nil), // 52: saasapi.TargetCreateRes
+	(*TargetDeleteRes)(nil), // 53: saasapi.TargetDeleteRes
+	(*Binds)(nil),           // 54: saasapi.Binds
+	(*Bind)(nil),            // 55: saasapi.Bind
+	(*BindSetRes)(nil),      // 56: saasapi.BindSetRes
+	(*BindDeleteRes)(nil),   // 57: saasapi.BindDeleteRes
+	(*BindError)(nil),       // 58: saasapi.BindError
+	(*GrantListRes)(nil),    // 59: saasapi.GrantListRes
+	(*ScriptDebugRes)(nil),  // 60: saasapi.ScriptDebugRes
+	(*ScriptInfo)(nil),      // 61: saasapi.ScriptInfo
+	(*ScriptCreateRes)(nil), // 62: saasapi.ScriptCreateRes
+	(*ScriptListRes)(nil),   // 63: saasapi.ScriptListRes
+	(*ScriptGetRes)(nil),    // 64: saasapi.ScriptGetRes
+	(*ScriptDeleteRes)(nil), // 65: saasapi.ScriptDeleteRes
+	(*ScriptUseRes)(nil),    // 66: saasapi.ScriptUseRes
+	(*ExpListRes)(nil),      // 67: saasapi.ExpListRes
+	(*ExpBucket)(nil),       // 68: saasapi.ExpBucket
+	(*ExpGetRes)(nil),       // 69: saasapi.ExpGetRes
+	(*ExpData)(nil),         // 70: saasapi.ExpData
+	(*ExpBaseFields)(nil),   // 71: saasapi.ExpBaseFields
+	(*ExpGrantListRes)(nil), // 72: saasapi.ExpGrantListRes
+	nil,                     // 73: saasapi.WriteItem.BytesKvEntry
+	nil,                     // 74: saasapi.WriteItem.Uint32sKvEntry
+	nil,                     // 75: saasapi.WriteItem.FlagsWithExpireKvEntry
+	nil,                     // 76: saasapi.ValueItem.BytesKvEntry
+	nil,                     // 77: saasapi.ValueItem.Uint32sKvEntry
+	nil,                     // 78: saasapi.ValueItem.FlagsWithExpireKvEntry
+	nil,                     // 79: saasapi.TargetListRes.TargetListEntry
+	nil,                     // 80: saasapi.ExpData.ExtFieldsEntry
+	nil,                     // 81: saasapi.ExpData.GroupEntry
 }
 var file_cmd_proto_depIdxs = []int32{
 	8,   // 0: saasapi.SaasReq.info:type_name -> saasapi.Info
 	9,   // 1: saasapi.SaasReq.read:type_name -> saasapi.Read
 	11,  // 2: saasapi.SaasReq.write:type_name -> saasapi.Write
 	17,  // 3: saasapi.SaasReq.column_write:type_name -> saasapi.ColumnWrite
-	18,  // 4: saasapi.SaasReq.task_create:type_name -> saasapi.Task
-	19,  // 5: saasapi.SaasReq.task_list:type_name -> saasapi.TaskList
-	20,  // 6: saasapi.SaasReq.task_run:type_name -> saasapi.TaskRun
-	21,  // 7: saasapi.SaasReq.task_delete:type_name -> saasapi.TaskDelete
-	22,  // 8: saasapi.SaasReq.task_info:type_name -> saasapi.TaskInfo
-	25,  // 9: saasapi.SaasReq.target_list:type_name -> saasapi.TargetList
-	26,  // 10: saasapi.SaasReq.target_create:type_name -> saasapi.TargetCreate
-	27,  // 11: saasapi.SaasReq.target_delete:type_name -> saasapi.TargetDelete
-	28,  // 12: saasapi.SaasReq.bind_set:type_name -> saasapi.BindSet
-	29,  // 13: saasapi.SaasReq.bind_delete:type_name -> saasapi.BindDelete
-	30,  // 14: saasapi.SaasReq.grant_list:type_name -> saasapi.GrantList
-	31,  // 15: saasapi.SaasReq.grant_add:type_name -> saasapi.Grant
-	31,  // 16: saasapi.SaasReq.grant_delete:type_name -> saasapi.Grant
-	32,  // 17: saasapi.SaasReq.script_debug:type_name -> saasapi.ScriptDebug
-	33,  // 18: saasapi.SaasReq.script_create:type_name -> saasapi.ScriptCreate
-	34,  // 19: saasapi.SaasReq.script_list:type_name -> saasapi.ScriptList
-	35,  // 20: saasapi.SaasReq.script_delete:type_name -> saasapi.ScriptDelete
-	36,  // 21: saasapi.SaasReq.script_get:type_name -> saasapi.ScriptGet
-	37,  // 22: saasapi.SaasReq.script_use:type_name -> saasapi.ScriptUse
-	38,  // 23: saasapi.SaasReq.exp_list:type_name -> saasapi.ExpList
-	39,  // 24: saasapi.SaasReq.exp_get:type_name -> saasapi.ExpGet
-	40,  // 25: saasapi.SaasReq.exp_grant_list:type_name -> saasapi.ExpGrantList
-	41,  // 26: saasapi.SaasReq.exp_grant_add:type_name -> saasapi.ExpGrant
-	41,  // 27: saasapi.SaasReq.exp_grant_delete:type_name -> saasapi.ExpGrant
-	10,  // 28: saasapi.Read.read_items:type_name -> saasapi.ReadItem
-	12,  // 29: saasapi.Write.write_items:type_name -> saasapi.WriteItem
-	13,  // 30: saasapi.WriteItem.write_bytes:type_name -> saasapi.Bytes
-	14,  // 31: saasapi.WriteItem.write_uint32s:type_name -> saasapi.Uint32s
-	15,  // 32: saasapi.WriteItem.write_flags_with_expire:type_name -> saasapi.FlagsWithExpire
-	71,  // 33: saasapi.WriteItem.bytes_kv:type_name -> saasapi.WriteItem.BytesKvEntry
-	72,  // 34: saasapi.WriteItem.uint32s_kv:type_name -> saasapi.WriteItem.Uint32sKvEntry
-	73,  // 35: saasapi.WriteItem.flags_with_expire_kv:type_name -> saasapi.WriteItem.FlagsWithExpireKvEntry
-	16,  // 36: saasapi.FlagsWithExpire.flags_with_expire:type_name -> saasapi.FlagWithExpire
-	13,  // 37: saasapi.ColumnWrite.write_bytes:type_name -> saasapi.Bytes
-	14,  // 38: saasapi.ColumnWrite.write_uint32s:type_name -> saasapi.Uint32s
-	15,  // 39: saasapi.ColumnWrite.write_flags_with_expire:type_name -> saasapi.FlagsWithExpire
-	23,  // 40: saasapi.Task.task_file_infos:type_name -> saasapi.FileInfo
-	4,   // 41: saasapi.Task.status:type_name -> saasapi.TaskStatus
-	4,   // 42: saasapi.TaskList.status_filter:type_name -> saasapi.TaskStatus
-	24,  // 43: saasapi.FileInfo.file_blocks:type_name -> saasapi.FileBlock
-	53,  // 44: saasapi.BindSet.binds:type_name -> saasapi.Bind
-	53,  // 45: saasapi.BindDelete.binds:type_name -> saasapi.Bind
-	5,   // 46: saasapi.ScriptDebug.os:type_name -> saasapi.OS
-	2,   // 47: saasapi.SaasRes.code:type_name -> saasapi.ErrorCode
-	44,  // 48: saasapi.SaasRes.info_res:type_name -> saasapi.InfoRes
-	45,  // 49: saasapi.SaasRes.read_res:type_name -> saasapi.ReadRes
-	46,  // 50: saasapi.SaasRes.write_res:type_name -> saasapi.WriteRes
-	18,  // 51: saasapi.SaasRes.task_create_res:type_name -> saasapi.Task
-	48,  // 52: saasapi.SaasRes.task_list_res:type_name -> saasapi.TaskListRes
-	18,  // 53: saasapi.SaasRes.task_run_res:type_name -> saasapi.Task
-	18,  // 54: saasapi.SaasRes.task_delete_res:type_name -> saasapi.Task
-	18,  // 55: saasapi.SaasRes.task_info_res:type_name -> saasapi.Task
-	49,  // 56: saasapi.SaasRes.target_list_res:type_name -> saasapi.TargetListRes
-	50,  // 57: saasapi.SaasRes.target_create_res:type_name -> saasapi.TargetCreateRes
-	51,  // 58: saasapi.SaasRes.target_delete_res:type_name -> saasapi.TargetDeleteRes
-	54,  // 59: saasapi.SaasRes.bind_set_res:type_name -> saasapi.BindSetRes
-	55,  // 60: saasapi.SaasRes.bind_delete_res:type_name -> saasapi.BindDeleteRes
-	57,  // 61: saasapi.SaasRes.grant_list_res:type_name -> saasapi.GrantListRes
-	31,  // 62: saasapi.SaasRes.grant_add_res:type_name -> saasapi.Grant
-	31,  // 63: saasapi.SaasRes.grant_delete_res:type_name -> saasapi.Grant
-	58,  // 64: saasapi.SaasRes.script_debug_res:type_name -> saasapi.ScriptDebugRes
-	60,  // 65: saasapi.SaasRes.script_create_res:type_name -> saasapi.ScriptCreateRes
-	61,  // 66: saasapi.SaasRes.script_list_res:type_name -> saasapi.ScriptListRes
-	63,  // 67: saasapi.SaasRes.script_delete_res:type_name -> saasapi.ScriptDeleteRes
-	62,  // 68: saasapi.SaasRes.script_get_res:type_name -> saasapi.ScriptGetRes
-	64,  // 69: saasapi.SaasRes.script_use_res:type_name -> saasapi.ScriptUseRes
-	65,  // 70: saasapi.SaasRes.exp_list_res:type_name -> saasapi.ExpListRes
-	67,  // 71: saasapi.SaasRes.exp_get_res:type_name -> saasapi.ExpGetRes
-	70,  // 72: saasapi.SaasRes.exp_grant_list_res:type_name -> saasapi.ExpGrantListRes
-	41,  // 73: saasapi.SaasRes.exp_grant_add_res:type_name -> saasapi.ExpGrant
-	41,  // 74: saasapi.SaasRes.exp_grant_delete_res:type_name -> saasapi.ExpGrant
-	43,  // 75: saasapi.InfoRes.dataspace:type_name -> saasapi.DataSpace
-	47,  // 76: saasapi.ReadRes.cmd_res:type_name -> saasapi.ValueItem
-	3,   // 77: saasapi.ValueItem.cmd_code:type_name -> saasapi.CmdErrorCode
-	16,  // 78: saasapi.ValueItem.flags_with_expire:type_name -> saasapi.FlagWithExpire
-	74,  // 79: saasapi.ValueItem.bytes_kv:type_name -> saasapi.ValueItem.BytesKvEntry
-	75,  // 80: saasapi.ValueItem.uint32s_kv:type_name -> saasapi.ValueItem.Uint32sKvEntry
-	76,  // 81: saasapi.ValueItem.flags_with_expire_kv:type_name -> saasapi.ValueItem.FlagsWithExpireKvEntry
-	18,  // 82: saasapi.TaskListRes.tasks:type_name -> saasapi.Task
-	77,  // 83: saasapi.TargetListRes.target_list:type_name -> saasapi.TargetListRes.TargetListEntry
-	53,  // 84: saasapi.Binds.binds:type_name -> saasapi.Bind
-	0,   // 85: saasapi.Bind.bind_type:type_name -> saasapi.BindType
-	1,   // 86: saasapi.Bind.bind_source:type_name -> saasapi.BindSourceType
-	56,  // 87: saasapi.BindSetRes.errors:type_name -> saasapi.BindError
-	56,  // 88: saasapi.BindDeleteRes.errors:type_name -> saasapi.BindError
-	31,  // 89: saasapi.GrantListRes.from:type_name -> saasapi.Grant
-	31,  // 90: saasapi.GrantListRes.to:type_name -> saasapi.Grant
-	59,  // 91: saasapi.ScriptCreateRes.script_info:type_name -> saasapi.ScriptInfo
-	59,  // 92: saasapi.ScriptListRes.script_info:type_name -> saasapi.ScriptInfo
-	59,  // 93: saasapi.ScriptGetRes.script_info:type_name -> saasapi.ScriptInfo
-	59,  // 94: saasapi.ScriptDeleteRes.script_info:type_name -> saasapi.ScriptInfo
-	59,  // 95: saasapi.ScriptUseRes.script_info:type_name -> saasapi.ScriptInfo
-	66,  // 96: saasapi.ExpListRes.buckets:type_name -> saasapi.ExpBucket
-	68,  // 97: saasapi.ExpGetRes.exp_data:type_name -> saasapi.ExpData
-	69,  // 98: saasapi.ExpData.base_fields:type_name -> saasapi.ExpBaseFields
-	78,  // 99: saasapi.ExpData.ext_fields:type_name -> saasapi.ExpData.ExtFieldsEntry
-	79,  // 100: saasapi.ExpData.group:type_name -> saasapi.ExpData.GroupEntry
-	41,  // 101: saasapi.ExpGrantListRes.from:type_name -> saasapi.ExpGrant
-	41,  // 102: saasapi.ExpGrantListRes.to:type_name -> saasapi.ExpGrant
-	16,  // 103: saasapi.WriteItem.FlagsWithExpireKvEntry.value:type_name -> saasapi.FlagWithExpire
-	16,  // 104: saasapi.ValueItem.FlagsWithExpireKvEntry.value:type_name -> saasapi.FlagWithExpire
-	52,  // 105: saasapi.TargetListRes.TargetListEntry.value:type_name -> saasapi.Binds
-	106, // [106:106] is the sub-list for method output_type
-	106, // [106:106] is the sub-list for method input_type
-	106, // [106:106] is the sub-list for extension type_name
-	106, // [106:106] is the sub-list for extension extendee
-	0,   // [0:106] is the sub-list for field type_name
+	18,  // 4: saasapi.SaasReq.reset_ds:type_name -> saasapi.ResetDs
+	19,  // 5: saasapi.SaasReq.task_create:type_name -> saasapi.Task
+	20,  // 6: saasapi.SaasReq.task_list:type_name -> saasapi.TaskList
+	21,  // 7: saasapi.SaasReq.task_run:type_name -> saasapi.TaskRun
+	22,  // 8: saasapi.SaasReq.task_delete:type_name -> saasapi.TaskDelete
+	23,  // 9: saasapi.SaasReq.task_info:type_name -> saasapi.TaskInfo
+	26,  // 10: saasapi.SaasReq.target_list:type_name -> saasapi.TargetList
+	27,  // 11: saasapi.SaasReq.target_create:type_name -> saasapi.TargetCreate
+	28,  // 12: saasapi.SaasReq.target_delete:type_name -> saasapi.TargetDelete
+	29,  // 13: saasapi.SaasReq.bind_set:type_name -> saasapi.BindSet
+	30,  // 14: saasapi.SaasReq.bind_delete:type_name -> saasapi.BindDelete
+	31,  // 15: saasapi.SaasReq.grant_list:type_name -> saasapi.GrantList
+	32,  // 16: saasapi.SaasReq.grant_add:type_name -> saasapi.Grant
+	32,  // 17: saasapi.SaasReq.grant_delete:type_name -> saasapi.Grant
+	33,  // 18: saasapi.SaasReq.script_debug:type_name -> saasapi.ScriptDebug
+	34,  // 19: saasapi.SaasReq.script_create:type_name -> saasapi.ScriptCreate
+	35,  // 20: saasapi.SaasReq.script_list:type_name -> saasapi.ScriptList
+	36,  // 21: saasapi.SaasReq.script_delete:type_name -> saasapi.ScriptDelete
+	37,  // 22: saasapi.SaasReq.script_get:type_name -> saasapi.ScriptGet
+	38,  // 23: saasapi.SaasReq.script_use:type_name -> saasapi.ScriptUse
+	39,  // 24: saasapi.SaasReq.exp_list:type_name -> saasapi.ExpList
+	40,  // 25: saasapi.SaasReq.exp_get:type_name -> saasapi.ExpGet
+	41,  // 26: saasapi.SaasReq.exp_grant_list:type_name -> saasapi.ExpGrantList
+	42,  // 27: saasapi.SaasReq.exp_grant_add:type_name -> saasapi.ExpGrant
+	42,  // 28: saasapi.SaasReq.exp_grant_delete:type_name -> saasapi.ExpGrant
+	10,  // 29: saasapi.Read.read_items:type_name -> saasapi.ReadItem
+	12,  // 30: saasapi.Write.write_items:type_name -> saasapi.WriteItem
+	13,  // 31: saasapi.WriteItem.write_bytes:type_name -> saasapi.Bytes
+	14,  // 32: saasapi.WriteItem.write_uint32s:type_name -> saasapi.Uint32s
+	15,  // 33: saasapi.WriteItem.write_flags_with_expire:type_name -> saasapi.FlagsWithExpire
+	73,  // 34: saasapi.WriteItem.bytes_kv:type_name -> saasapi.WriteItem.BytesKvEntry
+	74,  // 35: saasapi.WriteItem.uint32s_kv:type_name -> saasapi.WriteItem.Uint32sKvEntry
+	75,  // 36: saasapi.WriteItem.flags_with_expire_kv:type_name -> saasapi.WriteItem.FlagsWithExpireKvEntry
+	16,  // 37: saasapi.FlagsWithExpire.flags_with_expire:type_name -> saasapi.FlagWithExpire
+	13,  // 38: saasapi.ColumnWrite.write_bytes:type_name -> saasapi.Bytes
+	14,  // 39: saasapi.ColumnWrite.write_uint32s:type_name -> saasapi.Uint32s
+	15,  // 40: saasapi.ColumnWrite.write_flags_with_expire:type_name -> saasapi.FlagsWithExpire
+	24,  // 41: saasapi.Task.task_file_infos:type_name -> saasapi.FileInfo
+	4,   // 42: saasapi.Task.status:type_name -> saasapi.TaskStatus
+	4,   // 43: saasapi.TaskList.status_filter:type_name -> saasapi.TaskStatus
+	25,  // 44: saasapi.FileInfo.file_blocks:type_name -> saasapi.FileBlock
+	55,  // 45: saasapi.BindSet.binds:type_name -> saasapi.Bind
+	55,  // 46: saasapi.BindDelete.binds:type_name -> saasapi.Bind
+	5,   // 47: saasapi.ScriptDebug.os:type_name -> saasapi.OS
+	2,   // 48: saasapi.SaasRes.code:type_name -> saasapi.ErrorCode
+	45,  // 49: saasapi.SaasRes.info_res:type_name -> saasapi.InfoRes
+	46,  // 50: saasapi.SaasRes.read_res:type_name -> saasapi.ReadRes
+	47,  // 51: saasapi.SaasRes.write_res:type_name -> saasapi.WriteRes
+	49,  // 52: saasapi.SaasRes.reset_ds_res:type_name -> saasapi.ResetDsRes
+	19,  // 53: saasapi.SaasRes.task_create_res:type_name -> saasapi.Task
+	50,  // 54: saasapi.SaasRes.task_list_res:type_name -> saasapi.TaskListRes
+	19,  // 55: saasapi.SaasRes.task_run_res:type_name -> saasapi.Task
+	19,  // 56: saasapi.SaasRes.task_delete_res:type_name -> saasapi.Task
+	19,  // 57: saasapi.SaasRes.task_info_res:type_name -> saasapi.Task
+	51,  // 58: saasapi.SaasRes.target_list_res:type_name -> saasapi.TargetListRes
+	52,  // 59: saasapi.SaasRes.target_create_res:type_name -> saasapi.TargetCreateRes
+	53,  // 60: saasapi.SaasRes.target_delete_res:type_name -> saasapi.TargetDeleteRes
+	56,  // 61: saasapi.SaasRes.bind_set_res:type_name -> saasapi.BindSetRes
+	57,  // 62: saasapi.SaasRes.bind_delete_res:type_name -> saasapi.BindDeleteRes
+	59,  // 63: saasapi.SaasRes.grant_list_res:type_name -> saasapi.GrantListRes
+	32,  // 64: saasapi.SaasRes.grant_add_res:type_name -> saasapi.Grant
+	32,  // 65: saasapi.SaasRes.grant_delete_res:type_name -> saasapi.Grant
+	60,  // 66: saasapi.SaasRes.script_debug_res:type_name -> saasapi.ScriptDebugRes
+	62,  // 67: saasapi.SaasRes.script_create_res:type_name -> saasapi.ScriptCreateRes
+	63,  // 68: saasapi.SaasRes.script_list_res:type_name -> saasapi.ScriptListRes
+	65,  // 69: saasapi.SaasRes.script_delete_res:type_name -> saasapi.ScriptDeleteRes
+	64,  // 70: saasapi.SaasRes.script_get_res:type_name -> saasapi.ScriptGetRes
+	66,  // 71: saasapi.SaasRes.script_use_res:type_name -> saasapi.ScriptUseRes
+	67,  // 72: saasapi.SaasRes.exp_list_res:type_name -> saasapi.ExpListRes
+	69,  // 73: saasapi.SaasRes.exp_get_res:type_name -> saasapi.ExpGetRes
+	72,  // 74: saasapi.SaasRes.exp_grant_list_res:type_name -> saasapi.ExpGrantListRes
+	42,  // 75: saasapi.SaasRes.exp_grant_add_res:type_name -> saasapi.ExpGrant
+	42,  // 76: saasapi.SaasRes.exp_grant_delete_res:type_name -> saasapi.ExpGrant
+	44,  // 77: saasapi.InfoRes.dataspace:type_name -> saasapi.DataSpace
+	48,  // 78: saasapi.ReadRes.cmd_res:type_name -> saasapi.ValueItem
+	3,   // 79: saasapi.ValueItem.cmd_code:type_name -> saasapi.CmdErrorCode
+	16,  // 80: saasapi.ValueItem.flags_with_expire:type_name -> saasapi.FlagWithExpire
+	76,  // 81: saasapi.ValueItem.bytes_kv:type_name -> saasapi.ValueItem.BytesKvEntry
+	77,  // 82: saasapi.ValueItem.uint32s_kv:type_name -> saasapi.ValueItem.Uint32sKvEntry
+	78,  // 83: saasapi.ValueItem.flags_with_expire_kv:type_name -> saasapi.ValueItem.FlagsWithExpireKvEntry
+	19,  // 84: saasapi.TaskListRes.tasks:type_name -> saasapi.Task
+	79,  // 85: saasapi.TargetListRes.target_list:type_name -> saasapi.TargetListRes.TargetListEntry
+	55,  // 86: saasapi.Binds.binds:type_name -> saasapi.Bind
+	0,   // 87: saasapi.Bind.bind_type:type_name -> saasapi.BindType
+	1,   // 88: saasapi.Bind.bind_source:type_name -> saasapi.BindSourceType
+	58,  // 89: saasapi.BindSetRes.errors:type_name -> saasapi.BindError
+	58,  // 90: saasapi.BindDeleteRes.errors:type_name -> saasapi.BindError
+	32,  // 91: saasapi.GrantListRes.from:type_name -> saasapi.Grant
+	32,  // 92: saasapi.GrantListRes.to:type_name -> saasapi.Grant
+	61,  // 93: saasapi.ScriptCreateRes.script_info:type_name -> saasapi.ScriptInfo
+	61,  // 94: saasapi.ScriptListRes.script_info:type_name -> saasapi.ScriptInfo
+	61,  // 95: saasapi.ScriptGetRes.script_info:type_name -> saasapi.ScriptInfo
+	61,  // 96: saasapi.ScriptDeleteRes.script_info:type_name -> saasapi.ScriptInfo
+	61,  // 97: saasapi.ScriptUseRes.script_info:type_name -> saasapi.ScriptInfo
+	68,  // 98: saasapi.ExpListRes.buckets:type_name -> saasapi.ExpBucket
+	70,  // 99: saasapi.ExpGetRes.exp_data:type_name -> saasapi.ExpData
+	71,  // 100: saasapi.ExpData.base_fields:type_name -> saasapi.ExpBaseFields
+	80,  // 101: saasapi.ExpData.ext_fields:type_name -> saasapi.ExpData.ExtFieldsEntry
+	81,  // 102: saasapi.ExpData.group:type_name -> saasapi.ExpData.GroupEntry
+	42,  // 103: saasapi.ExpGrantListRes.from:type_name -> saasapi.ExpGrant
+	42,  // 104: saasapi.ExpGrantListRes.to:type_name -> saasapi.ExpGrant
+	16,  // 105: saasapi.WriteItem.FlagsWithExpireKvEntry.value:type_name -> saasapi.FlagWithExpire
+	16,  // 106: saasapi.ValueItem.FlagsWithExpireKvEntry.value:type_name -> saasapi.FlagWithExpire
+	54,  // 107: saasapi.TargetListRes.TargetListEntry.value:type_name -> saasapi.Binds
+	108, // [108:108] is the sub-list for method output_type
+	108, // [108:108] is the sub-list for method input_type
+	108, // [108:108] is the sub-list for extension type_name
+	108, // [108:108] is the sub-list for extension extendee
+	0,   // [0:108] is the sub-list for field type_name
 }
 
 func init() { file_cmd_proto_init() }
@@ -5728,6 +5862,7 @@ func file_cmd_proto_init() {
 		(*SaasReq_Read)(nil),
 		(*SaasReq_Write)(nil),
 		(*SaasReq_ColumnWrite)(nil),
+		(*SaasReq_ResetDs)(nil),
 		(*SaasReq_TaskCreate)(nil),
 		(*SaasReq_TaskList)(nil),
 		(*SaasReq_TaskRun)(nil),
@@ -5753,10 +5888,11 @@ func file_cmd_proto_init() {
 		(*SaasReq_ExpGrantAdd)(nil),
 		(*SaasReq_ExpGrantDelete)(nil),
 	}
-	file_cmd_proto_msgTypes[35].OneofWrappers = []any{
+	file_cmd_proto_msgTypes[36].OneofWrappers = []any{
 		(*SaasRes_InfoRes)(nil),
 		(*SaasRes_ReadRes)(nil),
 		(*SaasRes_WriteRes)(nil),
+		(*SaasRes_ResetDsRes)(nil),
 		(*SaasRes_TaskCreateRes)(nil),
 		(*SaasRes_TaskListRes)(nil),
 		(*SaasRes_TaskRunRes)(nil),
@@ -5788,7 +5924,7 @@ func file_cmd_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: unsafe.Slice(unsafe.StringData(file_cmd_proto_rawDesc), len(file_cmd_proto_rawDesc)),
 			NumEnums:      7,
-			NumMessages:   73,
+			NumMessages:   75,
 			NumExtensions: 0,
 			NumServices:   0,
 		},
diff --git a/cmd.proto b/cmd.proto
index d3b5fc7..ff308fa 100644
--- a/cmd.proto
+++ b/cmd.proto
@@ -12,6 +12,7 @@ message SaasReq {
         Read read                                = 10;  // 批量读取
         Write write                              = 11;  // 批量写入
         ColumnWrite column_write                 = 12;  // 全量列式写入
+        ResetDs reset_ds                         = 13;  // 清空数据区
 
         Task task_create                         = 20;  // 任务创建
         TaskList task_list                       = 21;  // 列出任务
@@ -26,9 +27,9 @@ message SaasReq {
         BindSet bind_set                         = 61;  // 设置绑定
         BindDelete bind_delete                   = 62;  // 解除绑定
 
-        GrantList grant_list                     = 70; // 列出数据授权
-        Grant grant_add                          = 71; // 增加数据授权
-        Grant grant_delete                       = 72; // 删除数据授权
+        GrantList grant_list                     = 70;  // 列出数据授权
+        Grant grant_add                          = 71;  // 增加数据授权
+        Grant grant_delete                       = 72;  // 删除数据授权
 
         ScriptDebug script_debug                 = 90;  // 调试脚本
         ScriptCreate script_create               = 91;  // 脚本创建
@@ -76,15 +77,15 @@ message WriteItem {
     Bytes write_bytes                            = 2 [deprecated = true];   // byte区域。!!!弃用，请使用bytes_kv
     Uint32s write_uint32s                        = 3 [deprecated = true];   // uint32区域。!!!弃用，请使用uint32s_kv
     FlagsWithExpire write_flags_with_expire      = 4 [deprecated = true];   // 标志位区域。!!!弃用，请使用flags_with_expire_kv
-    map<uint32, uint32> bytes_kv                 = 5;   // 写入byte，key为1-64索引值，value为0-255数值。index/value超限会丢弃
+    map<uint32, uint32> bytes_kv                 = 5;   // 写入uint8，key为1-64索引值，value为0-255数值。index/value超限会丢弃
     map<uint32, uint32> uint32s_kv               = 6;   // 写入uint32，key为1-8索引值，value为uint32数值。index超限会丢弃
     map<uint32, FlagWithExpire> flags_with_expire_kv    = 7;   // 写入标志位，key为1-4索引值，index超限会丢弃
 }
 
-// Bytes 写入byte区域
+// Bytes 写入uint8区域
 message Bytes {
-    bytes bytes                                  = 1;   // 写入的byte
-    uint64 index_1                               = 2;   // 写入byte的索引值(0..63)
+    bytes bytes                                  = 1;   // 写入的uint8
+    uint64 index_1                               = 2;   // 写入uint8的索引值(0..63)
 }
 
 // Uint32s 写入uint32区域
@@ -115,6 +116,11 @@ message ColumnWrite {
     FlagsWithExpire write_flags_with_expire      = 5;   // 标志位区域
 }
 
+// ResetDs 清空数据区命令
+message ResetDs {
+    string dataspace_id                          = 1;   // 数据空间ID
+}
+
 message Task {
     string dataspace_id                          = 1;   // 数据空间ID
     string appid                                 = 2;   // 小程序/小游戏/公众号/视频号的appid
@@ -283,6 +289,7 @@ message SaasRes {
 
         ReadRes read_res                         = 10;  // 读取命令返回
         WriteRes write_res                       = 11;  // 写入命令返回
+        ResetDsRes reset_ds_res                  = 13;  // 清空数据区命令返回
 
         Task task_create_res                     = 20;  // 创建任务返回状态
         TaskListRes task_list_res                = 21;  // 任务列表返回状态
@@ -359,6 +366,11 @@ message ValueItem {
     map<uint32, FlagWithExpire> flags_with_expire_kv    = 10;  // 标志位区域
 }
 
+// ResetDsRes 清空数据区返回
+message ResetDsRes {
+    string dataspace_id                          = 1;  // 数据空间ID
+}
+
 // TaskListRes 任务列表返回
 message TaskListRes {
     repeated Task tasks                          = 1;  // 任务列表
diff --git a/cmd/saastool/exp_get.go b/cmd/saastool/exp_get.go
index ee4cdfe..79dd6bf 100644
--- a/cmd/saastool/exp_get.go
+++ b/cmd/saastool/exp_get.go
@@ -94,7 +94,7 @@ func RunExpGet(args ...string) error {
 		groupBySlice = strings.Split(*groupBy, ",")
 		for _, group := range groupBySlice {
 			if !validGroupBy[group] {
-				return fmt.Errorf("Group by error. group:", group)
+				return fmt.Errorf("Group by error. group: %v", group)
 			}
 		}
 	}
diff --git a/cmd/saastool/help.go b/cmd/saastool/help.go
index 843371b..16b8e5c 100644
--- a/cmd/saastool/help.go
+++ b/cmd/saastool/help.go
@@ -19,6 +19,7 @@ Commands:
     write              Write user's 'bytes / uint32s / flags'
     read               Read user's 'bytes / uint32s / flags'
     columnwrite        Write columns for 'deviceid / openid' users
+    resetds            Reset data space
 
     convert            Convert data to write format
     
diff --git a/cmd/saastool/main.go b/cmd/saastool/main.go
index bd8820c..32a98af 100644
--- a/cmd/saastool/main.go
+++ b/cmd/saastool/main.go
@@ -27,6 +27,8 @@ func Run(args ...string) error {
 		return RunRead(args...)
 	case "columnwrite":
 		return RunColumnWrite(args...)
+	case "resetds":
+		return RunResetDs(args...)
 	case "convert":
 		return RunConvert(args...)
 	case "verify":
diff --git a/cmd/saastool/resetds.go b/cmd/saastool/resetds.go
new file mode 100644
index 0000000..a77fb49
--- /dev/null
+++ b/cmd/saastool/resetds.go
@@ -0,0 +1,71 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"net/http"
+
+	"git.algo.com.cn/public/saasapi"
+	"git.algo.com.cn/public/saasapi/pkg/saashttp"
+	"google.golang.org/protobuf/encoding/protojson"
+)
+
+type resetDsParams struct {
+	ds       string
+	saasHttp *saashttp.SaasClient
+}
+
+func RunResetDs(args ...string) error {
+	fs := flag.NewFlagSet("resetds", flag.ExitOnError)
+	cfgFile := paramConfig(fs)
+	ds := paramDataSpaceId(fs)
+
+	if err := fs.Parse(args); err != nil {
+		return fmt.Errorf("Command line parse error: %w", err)
+	}
+
+	if fs.NArg() > 0 || len(*ds) == 0 {
+		fs.PrintDefaults()
+		return nil
+	}
+
+	cfg, err := LoadConfigFile(*cfgFile)
+	if err != nil {
+		return fmt.Errorf("LoadConfigFile error: %w", err)
+	}
+
+	resetDsParams := resetDsParams{
+		ds: *ds,
+		saasHttp: &saashttp.SaasClient{
+			Client:  &http.Client{},
+			ApiUrls: saashttp.InitAPIUrl(&cfg.ApiUrls),
+			Auth:    &cfg.Auth,
+		},
+	}
+
+	return doResetDs(resetDsParams)
+}
+
+func doResetDs(resetDsParams resetDsParams) error {
+	saasReq := &saasapi.SaasReq{
+		Cmd: &saasapi.SaasReq_ResetDs{
+			ResetDs: &saasapi.ResetDs{
+				DataspaceId: resetDsParams.ds,
+			},
+		},
+	}
+
+	res, err := resetDsParams.saasHttp.ResetDS(saasReq)
+	if err != nil {
+		return fmt.Errorf("Submit Command error: %w", err)
+	}
+
+	if res.Code != saasapi.ErrorCode_SUCC {
+		return fmt.Errorf("Command failed. code:%v, status:%v", res.Code, res.Status)
+	}
+
+	resetRes := res.GetResetDsRes()
+
+	fmt.Printf("ResetDS res: %v\n", protojson.Format(resetRes))
+	return nil
+}
diff --git a/docker/build_saastool.sh b/docker/build_saastool.sh
index f6ab72c..d0769ad 100755
--- a/docker/build_saastool.sh
+++ b/docker/build_saastool.sh
@@ -3,8 +3,7 @@
 set -e
 
 docker buildx build --platform linux/amd64  \
-  -t rta-docker.pkg.coding.net/public/docker/saastool:latest \
-  -t rta-docker.pkg.coding.net/public/docker/saastool:2025121617 \
+  -t rta-docker.pkg.coding.net/public/docker/saastool:2026011117 \
   -o type=registry \
   -f saastool.Dockerfile \
   ../ ;
diff --git a/pkg/saashttp/cfg.go b/pkg/saashttp/cfg.go
index d11edc8..2ca7c01 100644
--- a/pkg/saashttp/cfg.go
+++ b/pkg/saashttp/cfg.go
@@ -6,6 +6,7 @@ const (
 	writePath          = "/saas/write"
 	readPath           = "/saas/read"
 	columnWritePath    = "/saas/column_write"
+	resetDSPath        = "/saas/resetds"
 	taskCreatePath     = "/saas/task/create"
 	taskListPath       = "/saas/task/list"
 	taskInfoPath       = "/saas/task/info"
@@ -45,6 +46,7 @@ type ApiUrls struct {
 	WritePath          string
 	ReadPath           string
 	ColumnWritePath    string
+	ResetDSPath        string
 	TaskCreatePath     string
 	TaskListPath       string
 	TaskInfoPath       string
@@ -100,6 +102,11 @@ func InitAPIUrl(c *ApiUrls) *ApiUrls {
 	} else {
 		r.ColumnWritePath = columnWritePath
 	}
+	if c.ResetDSPath != "" {
+		r.ResetDSPath = c.ResetDSPath
+	} else {
+		r.ResetDSPath = resetDSPath
+	}
 	if c.TaskCreatePath != "" {
 		r.TaskCreatePath = c.TaskCreatePath
 	} else {
diff --git a/pkg/saashttp/httpcli.go b/pkg/saashttp/httpcli.go
index 5c8e254..8570587 100644
--- a/pkg/saashttp/httpcli.go
+++ b/pkg/saashttp/httpcli.go
@@ -53,6 +53,11 @@ func (c *SaasClient) ColumnWrite(saasReq *saasapi.SaasReq) (saasRes *saasapi.Saa
 	return c.post(postUrl, saasReq)
 }
 
+func (c *SaasClient) ResetDS(saasReq *saasapi.SaasReq) (saasRes *saasapi.SaasRes, err error) {
+	postUrl := c.makeUrl(c.ApiUrls.BaseUrl, c.ApiUrls.ResetDSPath)
+	return c.post(postUrl, saasReq)
+}
+
 func (c *SaasClient) TaskCreate(saasReq *saasapi.SaasReq) (saasRes *saasapi.SaasRes, err error) {
 	postUrl := c.makeUrl(c.ApiUrls.BaseUrl, c.ApiUrls.TaskCreatePath)
 	return c.post(postUrl, saasReq)