Sitzung

C# AgentSession ist eine abstrakte Basisklasse. Konkrete Implementierungen (erstellt über CreateSessionAsync()) können zusätzlichen Zustand hinzufügen, z. B. eine ID für den Speicher des Remotechatverlaufs, wenn der vom Dienst verwaltete Verlauf verwendet wird.

Sitzungen bieten typgesteuerten Schlüsselwertspeicher:

type UserPrefs struct {
    Theme    string `json:"theme"`
    Language string `json:"language"`
}

session.Set("user_prefs", UserPrefs{Theme: "dark", Language: "en"})

var prefs UserPrefs
session.Get("user_prefs", &prefs)

session.Delete("user_prefs")

AgentSession session = await agent.CreateSessionAsync();

var first = await agent.RunAsync("My name is Alice.", session);
var second = await agent.RunAsync("What is my name?", session);

session = agent.create_session()

first = await agent.run("My name is Alice.", session=session)
second = await agent.run("What is my name?", session=session)

session, err := a.CreateSession(ctx)
if err != nil {
    panic(err)
}

resp, _ := a.RunText(ctx, "Hello!", agent.WithSession(session)).Collect()
resp, _ = a.RunText(ctx, "Follow-up question.", agent.WithSession(session)).Collect()

Der Standardwert von HarnessAgent ist InMemoryChatHistoryProvider. Ersetzen Sie ihn über den Zeitpunkt, an HarnessAgentOptions.ChatHistoryProvider dem der Verlauf einen anderen Speicher verwenden muss. AsHarnessAgent(options) ist Kurzhand für die Konstruktion new HarnessAgent(chatClient, options).

HarnessAgent agent = chatClient.AsHarnessAgent();
AgentSession session = await agent.CreateSessionAsync();

await agent.RunAsync("Plan the migration.", session);
await agent.RunAsync("Continue with the next step.", session);

var serialized = await agent.SerializeSessionAsync(session);
AgentSession resumed = await agent.DeserializeSessionAsync(serialized);

Die Nutzungsfunktion behält den lokalen Chatverlauf nach jedem Modellaufruf in einer Toolanrufschleife bei, nicht nur nach der Ausführung des äußeren Agents. Übergeben Sie die gleiche Sitzung weiter, um den In-Loop-Verlauf und den Status der Standardkontextanbieter beizubehalten.

create_harness_agent history_provider standardmäßig auf InMemoryHistoryProvider(). Übergeben Sie einen benutzerdefinierten HistoryProviderhistory_provider= Durchlauf, wenn der Verlauf einen anderen Speicher verwenden muss.

agent = create_harness_agent(client)
session = agent.create_session()

await agent.run("Plan the migration.", session=session)
await agent.run("Continue with the next step.", session=session)

serialized = session.to_dict()
resumed = AgentSession.from_dict(serialized)

Die Verwendung erfordert persistenz pro Dienstaufrufverlauf, sodass der konfigurierte Verlaufsanbieter jeden Modellaufruf in einer Toolschleife speichert. Eine Sitzung ist auch von der standardmäßigen Middleware für die Toolgenehmigung erforderlich. sie wiederzuverwenden und wiederherzustellen, um den Genehmigungs- und Kontextanbieterstatus beizubehalten.

Der Nutzungs-Agent ist derzeit nicht im Go SDK verfügbar. Verwenden Sie das oben gezeigte normale Sitzungsmuster.

Erstellen einer neuen Sitzung aus einer vorhandenen Unterhaltungs-ID variiert je nach Agenttyp. Im Folgenden finden Sie einige Beispiele hierfür.

Bei der Verwendung von ChatClientAgent

AgentSession session = await chatClientAgent.CreateSessionAsync(conversationId);

Bei Verwendung einer A2AAgent

AgentSession session = await a2aAgent.CreateSessionAsync(contextId, taskId);

Verwenden Sie dies, wenn der unterstützende Dienst bereits über einen Gesprächszustand verfügt.

session = agent.get_session(service_session_id="<service-conversation-id>")
response = await agent.run("Continue this conversation.", session=session)

Lösen Sie in gehosteten Apps <service-conversation-id> im anwendungseigenen Speicher auf, nachdem der aktuelle Benutzer oder Mandant überprüft wurde. Akzeptieren Sie keine rohen serverseitigen IDs von einem Client, es sei denn, Sie verifizieren zuvor, dass dem Aufrufer die Konversation gehört.

var serialized = agent.SerializeSession(session);
AgentSession resumed = await agent.DeserializeSessionAsync(serialized);

serialized = session.to_dict()
resumed = AgentSession.from_dict(serialized)

data, err := json.Marshal(session)
if err != nil {
    panic(err)
}

// Save to disk, database, etc.
if err := os.WriteFile("session.json", data, 0o644); err != nil {
    panic(err)
}

// Later, restore the session.
loaded, err := os.ReadFile("session.json")
if err != nil {
    panic(err)
}

var resumedSession agent.Session
if err := json.Unmarshal(loaded, &resumedSession); err != nil {
    panic(err)
}

resp, _ := a.RunText(ctx, "Continue from where we left off.", agent.WithSession(&resumedSession)).Collect()