in python/src/tablestore_for_agent_memory/util/tablestore_helper.py [0:0]
def search_response_to_message(search_response: tablestore.SearchResponse) -> (List[Message], Optional[str]):
messages = []
next_token = search_response.next_token
if next_token:
next_token = base64.b64encode(next_token).decode('utf-8')
else:
next_token = None
for hit in search_response.search_hits:
row = hit.row
session_id = row[0][0][1]
create_time = row[0][1][1]
message_id = row[0][2][1]
meta_data = {}
content = None
for col in row[1]:
key = col[0]
val = col[1]
if key == "content":
content = val
continue
meta_data[key] = val
message = Message(session_id=session_id, message_id=message_id, create_time=create_time, content=content, metadata=meta_data)
messages.append(message)
return messages, next_token