Skip to content

Commit 2c32f26

Browse files
committed
Support API SearchMemories.
1 parent 84555eb commit 2c32f26

9 files changed

Lines changed: 515 additions & 2 deletions

File tree

polardb-20170801/ChangeLog.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
2026-04-10 Version: 6.10.0
2+
- Support API SearchMemories.
3+
- Update API DescribeDBClusterAttribute: add response parameters Body.Branch.
4+
5+
16
2026-04-08 Version: 6.9.6
27
- Update API CreateApplication: add request parameters Parameters.
38

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '6.9.6'
1+
__version__ = '6.10.0'

polardb-20170801/alibabacloud_polardb20170801/client.py

Lines changed: 94 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28349,6 +28349,100 @@ async def revoke_account_privilege_zonal_async(
2834928349
runtime = RuntimeOptions()
2835028350
return await self.revoke_account_privilege_zonal_with_options_async(request, runtime)
2835128351

28352+
def search_memories_with_options(
28353+
self,
28354+
request: main_models.SearchMemoriesRequest,
28355+
runtime: RuntimeOptions,
28356+
) -> main_models.SearchMemoriesResponse:
28357+
request.validate()
28358+
query = {}
28359+
if not DaraCore.is_null(request.application_id):
28360+
query['ApplicationId'] = request.application_id
28361+
if not DaraCore.is_null(request.create_time_begin):
28362+
query['CreateTimeBegin'] = request.create_time_begin
28363+
if not DaraCore.is_null(request.create_time_end):
28364+
query['CreateTimeEnd'] = request.create_time_end
28365+
if not DaraCore.is_null(request.memory_agent_id):
28366+
query['MemoryAgentId'] = request.memory_agent_id
28367+
if not DaraCore.is_null(request.memory_user_id):
28368+
query['MemoryUserId'] = request.memory_user_id
28369+
if not DaraCore.is_null(request.query):
28370+
query['Query'] = request.query
28371+
if not DaraCore.is_null(request.top_k):
28372+
query['TopK'] = request.top_k
28373+
req = open_api_util_models.OpenApiRequest(
28374+
query = Utils.query(query)
28375+
)
28376+
params = open_api_util_models.Params(
28377+
action = 'SearchMemories',
28378+
version = '2017-08-01',
28379+
protocol = 'HTTPS',
28380+
pathname = '/',
28381+
method = 'POST',
28382+
auth_type = 'AK',
28383+
style = 'RPC',
28384+
req_body_type = 'formData',
28385+
body_type = 'json'
28386+
)
28387+
return DaraCore.from_map(
28388+
main_models.SearchMemoriesResponse(),
28389+
self.call_api(params, req, runtime)
28390+
)
28391+
28392+
async def search_memories_with_options_async(
28393+
self,
28394+
request: main_models.SearchMemoriesRequest,
28395+
runtime: RuntimeOptions,
28396+
) -> main_models.SearchMemoriesResponse:
28397+
request.validate()
28398+
query = {}
28399+
if not DaraCore.is_null(request.application_id):
28400+
query['ApplicationId'] = request.application_id
28401+
if not DaraCore.is_null(request.create_time_begin):
28402+
query['CreateTimeBegin'] = request.create_time_begin
28403+
if not DaraCore.is_null(request.create_time_end):
28404+
query['CreateTimeEnd'] = request.create_time_end
28405+
if not DaraCore.is_null(request.memory_agent_id):
28406+
query['MemoryAgentId'] = request.memory_agent_id
28407+
if not DaraCore.is_null(request.memory_user_id):
28408+
query['MemoryUserId'] = request.memory_user_id
28409+
if not DaraCore.is_null(request.query):
28410+
query['Query'] = request.query
28411+
if not DaraCore.is_null(request.top_k):
28412+
query['TopK'] = request.top_k
28413+
req = open_api_util_models.OpenApiRequest(
28414+
query = Utils.query(query)
28415+
)
28416+
params = open_api_util_models.Params(
28417+
action = 'SearchMemories',
28418+
version = '2017-08-01',
28419+
protocol = 'HTTPS',
28420+
pathname = '/',
28421+
method = 'POST',
28422+
auth_type = 'AK',
28423+
style = 'RPC',
28424+
req_body_type = 'formData',
28425+
body_type = 'json'
28426+
)
28427+
return DaraCore.from_map(
28428+
main_models.SearchMemoriesResponse(),
28429+
await self.call_api_async(params, req, runtime)
28430+
)
28431+
28432+
def search_memories(
28433+
self,
28434+
request: main_models.SearchMemoriesRequest,
28435+
) -> main_models.SearchMemoriesResponse:
28436+
runtime = RuntimeOptions()
28437+
return self.search_memories_with_options(request, runtime)
28438+
28439+
async def search_memories_async(
28440+
self,
28441+
request: main_models.SearchMemoriesRequest,
28442+
) -> main_models.SearchMemoriesResponse:
28443+
runtime = RuntimeOptions()
28444+
return await self.search_memories_with_options_async(request, runtime)
28445+
2835228446
def set_polar_fs_file_quota_with_options(
2835328447
self,
2835428448
request: main_models.SetPolarFsFileQuotaRequest,

polardb-20170801/alibabacloud_polardb20170801/models/__init__.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -866,6 +866,9 @@
866866
from ._revoke_account_privilege_zonal_request import RevokeAccountPrivilegeZonalRequest
867867
from ._revoke_account_privilege_zonal_response_body import RevokeAccountPrivilegeZonalResponseBody
868868
from ._revoke_account_privilege_zonal_response import RevokeAccountPrivilegeZonalResponse
869+
from ._search_memories_request import SearchMemoriesRequest
870+
from ._search_memories_response_body import SearchMemoriesResponseBody
871+
from ._search_memories_response import SearchMemoriesResponse
869872
from ._set_polar_fs_file_quota_request import SetPolarFsFileQuotaRequest
870873
from ._set_polar_fs_file_quota_response_body import SetPolarFsFileQuotaResponseBody
871874
from ._set_polar_fs_file_quota_response import SetPolarFsFileQuotaResponse
@@ -984,6 +987,8 @@
984987
from ._describe_dbcluster_access_whitelist_response_body import DescribeDBClusterAccessWhitelistResponseBodyDBClusterSecurityGroups
985988
from ._describe_dbcluster_access_whitelist_response_body import DescribeDBClusterAccessWhitelistResponseBodyItemsDBClusterIPArray
986989
from ._describe_dbcluster_access_whitelist_response_body import DescribeDBClusterAccessWhitelistResponseBodyItems
990+
from ._describe_dbcluster_attribute_response_body import DescribeDBClusterAttributeResponseBodyBranchChildBranch
991+
from ._describe_dbcluster_attribute_response_body import DescribeDBClusterAttributeResponseBodyBranch
987992
from ._describe_dbcluster_attribute_response_body import DescribeDBClusterAttributeResponseBodyDBNodes
988993
from ._describe_dbcluster_attribute_response_body import DescribeDBClusterAttributeResponseBodyTags
989994
from ._describe_dbcluster_available_resources_response_body import DescribeDBClusterAvailableResourcesResponseBodyAvailableZonesSupportedEnginesAvailableResources
@@ -1153,6 +1158,7 @@
11531158
from ._modify_global_security_ipgroup_name_response_body import ModifyGlobalSecurityIPGroupNameResponseBodyGlobalSecurityIPGroup
11541159
from ._modify_global_security_ipgroup_relation_response_body import ModifyGlobalSecurityIPGroupRelationResponseBodyGlobalSecurityIPGroupRel
11551160
from ._modify_log_backup_policy_request import ModifyLogBackupPolicyRequestAdvancedLogPolicies
1161+
from ._search_memories_response_body import SearchMemoriesResponseBodyResults
11561162
from ._set_polar_fs_file_quota_request import SetPolarFsFileQuotaRequestFilePathQuotas
11571163
from ._tag_resources_request import TagResourcesRequestTag
11581164
from ._temp_modify_dbnode_request import TempModifyDBNodeRequestDBNode
@@ -2022,6 +2028,9 @@
20222028
RevokeAccountPrivilegeZonalRequest,
20232029
RevokeAccountPrivilegeZonalResponseBody,
20242030
RevokeAccountPrivilegeZonalResponse,
2031+
SearchMemoriesRequest,
2032+
SearchMemoriesResponseBody,
2033+
SearchMemoriesResponse,
20252034
SetPolarFsFileQuotaRequest,
20262035
SetPolarFsFileQuotaResponseBody,
20272036
SetPolarFsFileQuotaResponse,
@@ -2140,6 +2149,8 @@
21402149
DescribeDBClusterAccessWhitelistResponseBodyDBClusterSecurityGroups,
21412150
DescribeDBClusterAccessWhitelistResponseBodyItemsDBClusterIPArray,
21422151
DescribeDBClusterAccessWhitelistResponseBodyItems,
2152+
DescribeDBClusterAttributeResponseBodyBranchChildBranch,
2153+
DescribeDBClusterAttributeResponseBodyBranch,
21432154
DescribeDBClusterAttributeResponseBodyDBNodes,
21442155
DescribeDBClusterAttributeResponseBodyTags,
21452156
DescribeDBClusterAvailableResourcesResponseBodyAvailableZonesSupportedEnginesAvailableResources,
@@ -2309,6 +2320,7 @@
23092320
ModifyGlobalSecurityIPGroupNameResponseBodyGlobalSecurityIPGroup,
23102321
ModifyGlobalSecurityIPGroupRelationResponseBodyGlobalSecurityIPGroupRel,
23112322
ModifyLogBackupPolicyRequestAdvancedLogPolicies,
2323+
SearchMemoriesResponseBodyResults,
23122324
SetPolarFsFileQuotaRequestFilePathQuotas,
23132325
TagResourcesRequestTag,
23142326
TempModifyDBNodeRequestDBNode

polardb-20170801/alibabacloud_polardb20170801/models/_describe_dbcluster_attribute_response_body.py

Lines changed: 129 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ def __init__(
1616
auto_upgrade_minor_version: str = None,
1717
blktag_total: int = None,
1818
blktag_used: int = None,
19+
branch: main_models.DescribeDBClusterAttributeResponseBodyBranch = None,
1920
bursting_enabled: str = None,
2021
category: str = None,
2122
compress_storage_mode: str = None,
@@ -100,6 +101,7 @@ def __init__(
100101
self.blktag_total = blktag_total
101102
# Current blktag usage.
102103
self.blktag_used = blktag_used
104+
self.branch = branch
103105
self.bursting_enabled = bursting_enabled
104106
# [Product Series](https://help.aliyun.com/document_detail/183258.html), with values as follows:
105107
# * **Normal**: Cluster Edition
@@ -309,6 +311,8 @@ def __init__(
309311
self.zone_ids = zone_ids
310312

311313
def validate(self):
314+
if self.branch:
315+
self.branch.validate()
312316
if self.dbnodes:
313317
for v1 in self.dbnodes:
314318
if v1:
@@ -341,6 +345,9 @@ def to_map(self):
341345
if self.blktag_used is not None:
342346
result['BlktagUsed'] = self.blktag_used
343347

348+
if self.branch is not None:
349+
result['Branch'] = self.branch.to_map()
350+
344351
if self.bursting_enabled is not None:
345352
result['BurstingEnabled'] = self.bursting_enabled
346353

@@ -556,6 +563,10 @@ def from_map(self, m: dict = None):
556563
if m.get('BlktagUsed') is not None:
557564
self.blktag_used = m.get('BlktagUsed')
558565

566+
if m.get('Branch') is not None:
567+
temp_model = main_models.DescribeDBClusterAttributeResponseBodyBranch()
568+
self.branch = temp_model.from_map(m.get('Branch'))
569+
559570
if m.get('BurstingEnabled') is not None:
560571
self.bursting_enabled = m.get('BurstingEnabled')
561572

@@ -1087,3 +1098,121 @@ def from_map(self, m: dict = None):
10871098

10881099
return self
10891100

1101+
class DescribeDBClusterAttributeResponseBodyBranch(DaraModel):
1102+
def __init__(
1103+
self,
1104+
branch_lsn: str = None,
1105+
branch_time: str = None,
1106+
child_branch: List[main_models.DescribeDBClusterAttributeResponseBodyBranchChildBranch] = None,
1107+
parent_ins_name: str = None,
1108+
):
1109+
self.branch_lsn = branch_lsn
1110+
self.branch_time = branch_time
1111+
self.child_branch = child_branch
1112+
self.parent_ins_name = parent_ins_name
1113+
1114+
def validate(self):
1115+
if self.child_branch:
1116+
for v1 in self.child_branch:
1117+
if v1:
1118+
v1.validate()
1119+
1120+
def to_map(self):
1121+
result = dict()
1122+
_map = super().to_map()
1123+
if _map is not None:
1124+
result = _map
1125+
if self.branch_lsn is not None:
1126+
result['BranchLsn'] = self.branch_lsn
1127+
1128+
if self.branch_time is not None:
1129+
result['BranchTime'] = self.branch_time
1130+
1131+
result['ChildBranch'] = []
1132+
if self.child_branch is not None:
1133+
for k1 in self.child_branch:
1134+
result['ChildBranch'].append(k1.to_map() if k1 else None)
1135+
1136+
if self.parent_ins_name is not None:
1137+
result['ParentInsName'] = self.parent_ins_name
1138+
1139+
return result
1140+
1141+
def from_map(self, m: dict = None):
1142+
m = m or dict()
1143+
if m.get('BranchLsn') is not None:
1144+
self.branch_lsn = m.get('BranchLsn')
1145+
1146+
if m.get('BranchTime') is not None:
1147+
self.branch_time = m.get('BranchTime')
1148+
1149+
self.child_branch = []
1150+
if m.get('ChildBranch') is not None:
1151+
for k1 in m.get('ChildBranch'):
1152+
temp_model = main_models.DescribeDBClusterAttributeResponseBodyBranchChildBranch()
1153+
self.child_branch.append(temp_model.from_map(k1))
1154+
1155+
if m.get('ParentInsName') is not None:
1156+
self.parent_ins_name = m.get('ParentInsName')
1157+
1158+
return self
1159+
1160+
class DescribeDBClusterAttributeResponseBodyBranchChildBranch(DaraModel):
1161+
def __init__(
1162+
self,
1163+
branch_lsn: str = None,
1164+
branch_time: str = None,
1165+
dbcluster_description: str = None,
1166+
has_child: bool = None,
1167+
ins_name: str = None,
1168+
):
1169+
self.branch_lsn = branch_lsn
1170+
self.branch_time = branch_time
1171+
self.dbcluster_description = dbcluster_description
1172+
self.has_child = has_child
1173+
self.ins_name = ins_name
1174+
1175+
def validate(self):
1176+
pass
1177+
1178+
def to_map(self):
1179+
result = dict()
1180+
_map = super().to_map()
1181+
if _map is not None:
1182+
result = _map
1183+
if self.branch_lsn is not None:
1184+
result['BranchLsn'] = self.branch_lsn
1185+
1186+
if self.branch_time is not None:
1187+
result['BranchTime'] = self.branch_time
1188+
1189+
if self.dbcluster_description is not None:
1190+
result['DBClusterDescription'] = self.dbcluster_description
1191+
1192+
if self.has_child is not None:
1193+
result['HasChild'] = self.has_child
1194+
1195+
if self.ins_name is not None:
1196+
result['InsName'] = self.ins_name
1197+
1198+
return result
1199+
1200+
def from_map(self, m: dict = None):
1201+
m = m or dict()
1202+
if m.get('BranchLsn') is not None:
1203+
self.branch_lsn = m.get('BranchLsn')
1204+
1205+
if m.get('BranchTime') is not None:
1206+
self.branch_time = m.get('BranchTime')
1207+
1208+
if m.get('DBClusterDescription') is not None:
1209+
self.dbcluster_description = m.get('DBClusterDescription')
1210+
1211+
if m.get('HasChild') is not None:
1212+
self.has_child = m.get('HasChild')
1213+
1214+
if m.get('InsName') is not None:
1215+
self.ins_name = m.get('InsName')
1216+
1217+
return self
1218+

0 commit comments

Comments
 (0)