from memobase import MemoBaseClient
from memobase.core.blob import ChatBlob
client = MemoBaseClient(project_url='YOUR_PROJECT_URL', api_key='YOUR_API_KEY')
user = client.get_user('some_user_id')
# Create a data blob
blob = ChatBlob(messages=[
{"role": "user", "content": "Hi, I'm here again"},
{"role": "assistant", "content": "Hi, Gus! How can I help you?"}
])
# Asynchronous insert (default behavior)
blob_id = user.insert(blob)
# Asynchronous flush (default behavior)
user.flush()
# Synchronous flush (waits for completion)
user.flush(sync=True)