スレッド

このページでは、開発者向けのメッセージ・ヘルパー・タイプとともに、具体的なOracleスレッド・ハンドルを示します。

Oracleスレッド

クラス oracleagentmemory.core.OracleThread

ベース: IThread

Oracleストアに支えられたスレッド。

この実装では、スレッド・メッセージと手動で追加したメモリーの両方を埋め込んで格納し、格納されているすべてのレコードの類似性検索をサポートします。

ノート:

新しいOracleThreadインスタンスを作成します。

from oracleagentmemory.core import OracleAgentMemory
import oracledb
db_pool = oracledb.SessionPool(
    user="YOUR DB USER",
    password="YOUR DB PASSWORD",
    dsn="YOUR DB CONNECT STRING",
)
client = OracleAgentMemory(connection=db_pool, embedder=embedder)
thread = client.create_thread(
    thread_id="c1",
    llm=llm,
    memory_extraction_config=MemoryExtractionConfig(enable_context_summary=True),
)
len(thread.add_messages([{"role": "user", "content": "I love pizza."}]))
1

メソッド add_memory

手動メモリー・エントリを追加し、索引付けします。

thread.add_memory("Remember this preference", memory_id="mem-thread-docs")
'mem-thread-docs'

method add_memory_async (非同期)

メモリーを非同期的に追加します。

メソッド add_messages

スレッドにメッセージを追加し、索引付けします。

バックグラウンド抽出モードでは、このメソッドはRAWメッセージの挿入後に戻り、バックグラウンドでのバックグラウンド抽出が試行されます。

ノート:

MemoryExtractionMode.BACKGROUNDでは、抽出されたメモリーが格納される前にRAWメッセージが保持されます。バックグラウンド抽出がキューに入らない場合、または構成されたキュー容量の待機がタイムアウトに達した場合、挿入されたRAWメッセージは格納されたままになり、抽出されたメモリーなしでコールが続行されるか、background_extraction_queue_full_behaviorに応じてTimeoutErrorが呼び出されます。

len(thread.add_messages([{"role": "user", "content": "Thread message from docs"}]))
1

method add_messages_async (非同期)

スレッドにメッセージを非同期に追加し、インデックスを作成します。

バックグラウンド抽出モードでは、このメソッドはRAWメッセージの挿入後に戻り、バックグラウンドでのバックグラウンド抽出が試行されます。

MemoryExtractionMode.BACKGROUNDでは、抽出されたメモリーが格納される前にRAWメッセージが保持されます。バックグラウンド抽出がキューに入らない場合、または構成されたキュー容量の待機がタイムアウトに達した場合、挿入されたRAWメッセージは格納されたままになり、抽出されたメモリーなしでコールが続行されるか、background_extraction_queue_full_behaviorに応じてTimeoutErrorが呼び出されます。

メソッド delete_memory

メモリーに似たレコード(メモリー、ファクト、プリファレンス、ガイドラインなど)を、この正確なスレッドから識別子によって削除します。

thread.delete_memory("456")
0

メソッド delete_message

識別子によって、この正確なスレッドからメッセージ・レコードを削除します。

ノート:

メッセージを削除すると、RAWメッセージ・レコードのみが削除されます。導出された記憶は、どの抽出された記憶がどのメッセージから得られたかをまだ追跡していないため、削除されません。したがって、これらの記憶は検索可能なままになるか、コンテキスト・カードの出力に影響する可能性があります。OracleAgentMemory.delete_thread()を使用して、スレッドを関連するメッセージおよびメモリーとともに削除します。

thread.delete_message("123")
0

メソッド get_context_card

スレッドのコンテキスト・カード・オブジェクトを返します。

LLMがバックアップした実装でリモート・ネットワークI/Oを実行できる場合は、get_context_card_asyncを優先します。

ノート:

これは、スレッドのデフォルトの検索スコープをexact_thread_match=Falseとともに使用するため、同じユーザー/エージェントの他のスレッドからの関連メモリーが含まれる場合があります。

thread.add_memory("User likes pizza", memory_id="mem-context-docs")
'mem-context-docs'
len(thread.add_messages([{"role": "user", "content": "Tell me about pizza"}]))
1
"User likes pizza" in thread.get_context_card().content
True
card = thread.get_context_card(
    max_relevant_results=4,
    min_relevant_results_by_type={"memory": 1},
)
len(card.relevant_results or []) <= 4
True

method get_context_card_async (非同期)

スレッドのコンテキスト・カード・オブジェクトを非同期で返します。

card = await thread.get_context_card_async(
    min_relevant_results_by_type={"preference": 1, "guideline": 1},
)
len(card.relevant_results or []) <= 5
True

メソッド get_messages

このスレッドの格納されたメッセージを返します。

len(thread.add_messages([{"role": "user", "content": "Stored message example"}]))
1
messages = thread.get_messages()
messages[-1].content
'Stored message example'

method get_messages_async (非同期)

rawスレッドメッセージを非同期に返します。

メソッド get_summary

スレッドのベスト・エフォート・サマリーを返します。

LLMがバックアップした実装でリモート・ネットワークI/Oを実行できる場合は、get_summary_asyncを優先します。

len(thread.add_messages([{"role": "assistant", "content": "Summary source message"}]))
1
summary = thread.get_summary()
bool(summary.content)
True

method get_summary_async (非同期)

スレッドのベスト・エフォート・サマリーを非同期で返します。

クエリーに関連するレコードを同期的に検索します。

ノート:

省略されたスコープ・フィールドは、このスレッドのデフォルトの検索スコープ(正確なユーザーおよびエージェントの一致に加えて、このスレッドの現在のuser_idagent_idおよびthread_id)を継承します。デフォルトのスレッド検索は意図的にexact_thread_match=Falseを残すため、同じユーザー/エージェントの他のスレッドから関連レコードを返す場合があります。exact_thread_match=Trueを渡して、結果を現在のスレッドに制限します。明示的なNoneスコープ値は、解決された完全一致ルールに従います。exact_*_match=Falseはそのディメンションを制約なしのままにし、exact_*_match=Trueは格納されたNone値にのみ一致します。

明示的なmax_results値は、少なくとも1である必要があります。引数を省略すると、デフォルト値の10が使用されます。これは上限です。フィルタが制限しすぎる場合、一致するレコードの数が少ない場合、または実装固有の検索動作のため、コールはmax_resultsの結果より少ない場合があります。

method search_async (非同期)

クエリーに関連するレコードを非同期で検索します。

ノート:

省略されたスコープ・フィールドは、このスレッドのデフォルトの検索スコープ(正確なユーザーおよびエージェントの一致に加えて、このスレッドの現在のuser_idagent_idおよびthread_id)を継承します。デフォルトのスレッド検索は意図的にexact_thread_match=Falseを残すため、同じユーザー/エージェントの他のスレッドから関連レコードを返す場合があります。exact_thread_match=Trueを渡して、結果を現在のスレッドに制限します。明示的なNoneスコープ値は、解決された完全一致ルールに従います。exact_*_match=Falseはそのディメンションを制約なしのままにし、exact_*_match=Trueは格納されたNone値にのみ一致します。

明示的なmax_results値は、少なくとも1である必要があります。引数を省略すると、デフォルト値の10が使用されます。これは上限です。フィルタが制限しすぎる場合、一致するレコードの数が少ない場合、または実装固有の検索動作のため、コールはmax_resultsの結果より少ない場合があります。

メソッド update_memory

この正確なスレッドが所有するメモリーに似たレコードを更新します。

method update_memory_async (非同期)

メモリーに類似したレコードを非同期的に更新します。

from functools import partial
from oracleagentmemory._async_helpers import run_async_in_sync
memory_id = thread.add_memory("Original memory")
run_async_in_sync(
    partial(thread.update_memory_async, memory_id, content="Updated memory")
) == memory_id
True

メソッド update_message

この正確なスレッドが所有するRAWメッセージ・レコードを更新します。

ノート:

省略されたフィールドは、格納されたレコードから保持されます。格納されたロールとタイムスタンプは変更されません。コンテンツを編集するとRAWメッセージ履歴が更新され、自動抽出が有効な場合、SDKが編集されたメッセージおよび以前の履歴からメモリーを再抽出する可能性があります。INLINEモードでは、このメソッドが返される前に抽出が完了します。BACKGROUNDモードでは、このメソッドはRAWメッセージ更新が成功し、バックグラウンド抽出が試行された後に戻ります。このフォローアップ作業は、後のadd_messages()コールで使用される通常の抽出頻度には影響しません。既存の抽出済メモリーは、編集済コンテンツから新しく抽出されたメモリーを追加できる間、そのまま残ります。RAWメッセージ更新および後で抽出されたメモリー書込みは原子的に発生しないため、バックグラウンド処理がキューに入らない場合、構成されたキュー容量待機がタイムアウトに達した場合、または後で抽出処理が失敗した場合でも、抽出されたメモリーは以前のメッセージ内容を反映できます。また、既存の抽出済メモリーは、ソース・メッセージのTTLが変更されたときに元の有効期限を保持することに注意してください。

message_id = thread.add_messages([{"role": "user", "content": "Draft message"}])[0]
thread.update_message(message_id, content="Edited message") == message_id
True

method update_message_async (非同期)

この正確なスレッドが所有するRAWメッセージ・レコードを非同期的に更新します。

ノート:

省略されたフィールドは、格納されたレコードから保持されます。格納されたロールとタイムスタンプは変更されません。コンテンツを編集するとRAWメッセージ履歴が更新され、自動抽出が有効な場合、SDKが編集されたメッセージおよび以前の履歴からメモリーを再抽出する可能性があります。INLINEモードでは、このメソッドが返される前に抽出が完了します。BACKGROUNDモードでは、このメソッドはRAWメッセージ更新が成功し、バックグラウンド抽出が試行された後に戻ります。このフォローアップ作業は、後のadd_messages()コールで使用される通常の抽出頻度には影響しません。既存の抽出済メモリーは、編集済コンテンツから新しく抽出されたメモリーを追加できる間、そのまま残ります。RAWメッセージ更新および後で抽出されたメモリー書込みは原子的に発生しないため、バックグラウンド処理がキューに入らない場合、構成されたキュー容量待機がタイムアウトに達した場合、または後で抽出処理が失敗した場合でも、抽出されたメモリーは以前のメッセージ内容を反映できます。また、既存の抽出済メモリーは、ソース・メッセージのTTLが変更されたときに元の有効期限を保持することに注意してください。

message_id = thread.add_messages([{"role": "user", "content": "Draft message"}])[0]
run_async_in_sync(
    partial(thread.update_message_async, message_id, content="Edited message")
) == message_id
True

メソッド wait_for_memory_extraction

このスレッドの以前のバックグラウンドメモリー抽出を待ちます。

このメソッドは、同じエージェント・メモリー・コンポーネントを介して、以前のadd_messages()add_messages_async()update_message()またはupdate_message_async()コールによって開始されたバックグラウンド抽出を待機します。これらのコールのいずれかがすでに終了している場合、このメソッドには、待機前に開始する抽出が含まれます。

このメソッドは、この待機の開始後、別のエージェント・メモリー・コンポーネントによって開始された抽出、または別のプロセスで実行されている抽出の開始を待機しません。この待機の終了時に抽出の失敗がカウントされます。

thread.wait_for_memory_extraction(timeout=10)

method wait_for_memory_extraction_async (非同期)

以前のバックグラウンド・メモリー抽出を非同期に待機します。

このメソッドは、wait_for_memory_extraction()と同じ動作に従います。

await thread.wait_for_memory_extraction_async(timeout=10)

ノート: delete_message()は、RAWメッセージ行のみを削除します。導出された記憶は引き続き検索可能であるか、コンテキスト・カードに表示されます。OracleAgentMemory.delete_thread()を使用して、スレッドを関連するメッセージおよびメモリーとともに削除します。クライアント・レベルのスレッド削除は、そのスレッドですでに認識されている、以前に受け入れられたバックグラウンド抽出を待機しますが、削除の進行中は、同じスレッド上の他の操作に対するグローバルな同時実行性の障壁ではありません。

メッセージ

クラス oracleagentmemory.apis.thread.Message

ベース: object

コンテキスト・カード

クラス oracleagentmemory.apis.contextcard.ContextCard

ベース: ABC

スレッドAPIによって返される抽象コンテキスト・カード・オブジェクト。

property content (抽象)

クラス oracleagentmemory.core.contextcard.OracleContextCard

ベース: ContextCard

Oracleスレッドによって返されたコンテキスト・カード。

プロパティ content

card = OracleContextCard(summary="ctx")
"<summary>" in card.content and "ctx" in card.content
True

property formatted_content

OracleContextCard(summary="").formatted_content
''
card = OracleContextCard(summary="ctx", topics=["travel"])
"<topics>" in card.formatted_content
True

サマリー

クラス oracleagentmemory.apis.summary.Summary

ベース: ABC

スレッドAPIによって返される抽象スレッド・サマリー・オブジェクト。

property content (抽象)

クラス oracleagentmemory.core.summary.OracleSummary

ベース: Summary

Oracleスレッドによって返されるサマリー。

summary = OracleSummary(content="Plan the Rome itinerary.")
summary.content
'Plan the Rome itinerary.'
str(summary)
'Plan the Rome itinerary.'

プロパティ content

OracleSummary(content="Keep the tea preference in mind.").content
'Keep the tea preference in mind.'

property formatted_content

OracleSummary(content="Thread recap").formatted_content
'Thread recap'