Skip to content

Commit 91e96b7

Browse files
committed
fix: add sts token in viking memory sdk client
1 parent 6885d48 commit 91e96b7

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

veadk/integrations/ve_viking_db_memory/ve_viking_db_memory.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,9 @@ def setHeader(self, header):
9595
api_info[key].header[item] = header[item]
9696
self.api_info = api_info
9797

98+
def get_host(self):
99+
return self.service_info.host
100+
98101
@staticmethod
99102
def get_service_info(host, region, scheme, connection_timeout, socket_timeout):
100103
service_info = ServiceInfo(

veadk/memory/long_term_memory_backends/vikingdb_memory_backend.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,13 +122,15 @@ def _get_client(self) -> VikingDBMemoryClient:
122122
)
123123

124124
def _get_sdk_client(self) -> VikingMem:
125+
client = self._get_client()
125126
return VikingMem(
126-
host="api-knowledgebase.mlp.cn-beijing.volces.com",
127-
region="cn-beijing",
127+
host=client.get_host(),
128+
region=self.region,
128129
auth=IAM(
129130
ak=self.volcengine_access_key,
130131
sk=self.volcengine_secret_key,
131132
),
133+
sts_token=self.session_token,
132134
)
133135

134136
@override

0 commit comments

Comments
 (0)