View a markdown version of this page

将内容摄入长期记忆中 - 亚马逊基岩 AgentCore
何时使用 IngestDataIngestData 工作原理示例跟踪摄取进度

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

将内容摄入长期记忆中

用于直接提交内容IngestData以进行长期记忆提取，而不将其作为短期记忆事件保留。

何时使用 IngestData

IngestData当你需要将内容提炼到长期记忆中，但不需要将原始交互保留为可检索的事件时使用。例如：

  • 你只需要提取的内存记录，不需要逐字交互。

  • 你想避免持续保存一个你永远不会回读的事件所带来的短期存储开销。

  • 您的应用程序已经保留了原始交互，因此您只需要从中提取的长期记录即可。

由于IngestData不存储短期事件，因此无法使用、或ListSessions检索提交的内容 GetEventListEvents，也无法使用分支进行重组。

注意

要将原始交互保留为短期事件，请CreateEvent改用。

IngestData 工作原理

成功的请求确认您的内容已被接受；处理内容后，生成的长期内存记录便可用。

处理完成后，使用RetrieveMemoryRecordsListMemoryRecords、或 GetMemoryRecord — 与任何其他长期内存记录相同的操作来检索生成的长期内存记录。

IngestData支持两种有效载荷类型：

对话式

带有角色（例如USER或ASSISTANT）和文本内容的对话消息。

JSON

JSON-formatted 数据，例如行为事件、活动日志或系统事件。

您可以选择附加元数据来丰富提取的记录。有关更多信息，请参阅长期存储器的结构化元数据。

提取的记录的范围限定为命名空间。有关更多信息，请参见使用命名空间使用命名空间指定长期内存组织指定长期内存组织。

标actorId识会话中的实体（例如，最终用户或代理）和sessionId群组内容。在提取过程中，共享相同的actorIdsessionId、和命名空间的内容被视为相关的上下文。

注意

IngestData粉丝们对内存配置的长期内存策略感到满意，自我管理策略除外，这些策略有自己的内存处理工作流程。

示例

以下示例采集对话和非对话内容。

import boto3
from datetime import datetime

# Initialize the Boto3 client for data plane operations
data_client = boto3.client('bedrock-agentcore', region_name='us-west-2')

response = data_client.ingest_data(
    memoryId='mem-12345abcdef',
    actorId='customer-123',
    sessionId='session-456',
    contentTimestamp=datetime.now(),
    source={
        'inline': {
            'payload': [
                {
                    'conversational': {
                        'content': {'text': 'I prefer window seats on flights.'},
                        'role': 'USER'
                    }
                },
                {
                    'conversational': {
                        'content': {'text': "Noted — I'll remember your window seat preference."},
                        'role': 'ASSISTANT'
                    }
                },
                {
                    'json': {
                        'content': {
                            'customer_tier': 'gold',
                            'preferences': {'seat': 'window', 'meal': 'vegetarian'},
                            'loyalty_points': 48200
                        }
                    }
                }
            ]
        }
    }
)

# IngestData is asynchronous; the response echoes the session the content was ingested into.
print(f"Ingested content into session: {response['sessionId']}")

跟踪摄取进度

要跟踪成功请求后发生的情况并检测问题，请使用以下方法。

验证提取结果

摄取后，内存记录通常会在几秒到几分钟内出现，具体取决于内容大小和策略配置。要确认提取已完成，请执行以下操作：

处理提取失败

如果提取失败，则将失败的任务 AgentCore 移至内存资源的专用队列中。ListMemoryExtractionJobs用于查看失败的作业，并在StartMemoryExtractionJob解决根本原因后重新驱动这些任务。有关失败原因代码、补救步骤以及如何使用该FailedExtraction CloudWatch 指标设置主动监控，请参阅 Redrive 失败摄取。

要启用应用程序日志和跟踪以更深入地了解处理生命周期，请参阅启用 AgentCore 运行时、内存、网关、内置工具和身份资源的可观察性。