forked from microsoft/autogen
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
first draft of stateful persistence grains for each agent.... (micros…
…oft#3954) * adds Orleans persistence for AgentState
- Loading branch information
Showing
35 changed files
with
749 additions
and
77 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
21 changes: 21 additions & 0 deletions
21
dotnet/samples/Hello/HelloAgentState/HelloAgentState.csproj
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,21 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk"> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="..\..\..\src\Microsoft.AutoGen\Abstractions\Microsoft.AutoGen.Abstractions.csproj" /> | ||
| <ProjectReference Include="..\..\..\src\Microsoft.AutoGen\Agents\Microsoft.AutoGen.Agents.csproj" /> | ||
| <ProjectReference Include="..\..\..\src\Microsoft.AutoGen\Runtime\Microsoft.AutoGen.Runtime.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="Microsoft.Extensions.Hosting" /> | ||
| <PackageReference Include="Aspire.Hosting.AppHost" /> | ||
| </ItemGroup> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| </PropertyGroup> | ||
|
|
||
| </Project> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,75 @@ | ||
| // Copyright (c) Microsoft. All rights reserved. | ||
|
|
||
| using Microsoft.AutoGen.Abstractions; | ||
| using Microsoft.AutoGen.Agents; | ||
| using Microsoft.Extensions.DependencyInjection; | ||
| using Microsoft.Extensions.Hosting; | ||
|
|
||
| // send a message to the agent | ||
| var app = await AgentsApp.PublishMessageAsync("HelloAgents", new NewMessageReceived | ||
| { | ||
| Message = "World" | ||
| }, local: false); | ||
|
|
||
| await app.WaitForShutdownAsync(); | ||
|
|
||
| namespace Hello | ||
| { | ||
| [TopicSubscription("HelloAgents")] | ||
| public class HelloAgent( | ||
| IAgentContext context, | ||
| [FromKeyedServices("EventTypes")] EventTypes typeRegistry) : ConsoleAgent( | ||
| context, | ||
| typeRegistry), | ||
| ISayHello, | ||
| IHandle<NewMessageReceived>, | ||
| IHandle<ConversationClosed> | ||
| { | ||
| private AgentState? State { get; set; } | ||
| public async Task Handle(NewMessageReceived item) | ||
| { | ||
| var response = await SayHello(item.Message).ConfigureAwait(false); | ||
| var evt = new Output | ||
| { | ||
| Message = response | ||
| }.ToCloudEvent(this.AgentId.Key); | ||
| var entry = "We said hello to " + item.Message; | ||
| await Store(new AgentState | ||
| { | ||
| AgentId = this.AgentId, | ||
| TextData = entry | ||
| }).ConfigureAwait(false); | ||
| await PublishEvent(evt).ConfigureAwait(false); | ||
| var goodbye = new ConversationClosed | ||
| { | ||
| UserId = this.AgentId.Key, | ||
| UserMessage = "Goodbye" | ||
| }.ToCloudEvent(this.AgentId.Key); | ||
| await PublishEvent(goodbye).ConfigureAwait(false); | ||
| } | ||
| public async Task Handle(ConversationClosed item) | ||
| { | ||
| State = await Read<AgentState>(this.AgentId).ConfigureAwait(false); | ||
| var read = State?.TextData ?? "No state data found"; | ||
| var goodbye = $"{read}\n********************* {item.UserId} said {item.UserMessage} ************************"; | ||
| var evt = new Output | ||
| { | ||
| Message = goodbye | ||
| }.ToCloudEvent(this.AgentId.Key); | ||
| await PublishEvent(evt).ConfigureAwait(false); | ||
| //sleep | ||
| await Task.Delay(10000).ConfigureAwait(false); | ||
| await AgentsApp.ShutdownAsync().ConfigureAwait(false); | ||
|
|
||
| } | ||
| public async Task<string> SayHello(string ask) | ||
| { | ||
| var response = $"\n\n\n\n***************Hello {ask}**********************\n\n\n\n"; | ||
| return response; | ||
| } | ||
| } | ||
| public interface ISayHello | ||
| { | ||
| public Task<string> SayHello(string ask); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,138 @@ | ||
| # AutoGen 0.4 .NET Hello World Sample | ||
|
|
||
| This [sample](Program.cs) demonstrates how to create a simple .NET console application that listens for an event and then orchestrates a series of actions in response. | ||
|
|
||
| ## Prerequisites | ||
|
|
||
| To run this sample, you'll need: [.NET 8.0](https://dotnet.microsoft.com/en-us/) or later. | ||
| Also recommended is the [GitHub CLI](https://cli.github.com/). | ||
|
|
||
| ## Instructions to run the sample | ||
|
|
||
| ```bash | ||
| # Clone the repository | ||
| gh repo clone microsoft/autogen | ||
| cd dotnet/samples/Hello | ||
| dotnet run | ||
| ``` | ||
|
|
||
| ## Key Concepts | ||
|
|
||
| This sample illustrates how to create your own agent that inherits from a base agent and listens for an event. It also shows how to use the SDK's App Runtime locally to start the agent and send messages. | ||
|
|
||
| Flow Diagram: | ||
|
|
||
| ```mermaid | ||
| %%{init: {'theme':'forest'}}%% | ||
| graph LR; | ||
| A[Main] --> |"PublishEvent(NewMessage('World'))"| B{"Handle(NewMessageReceived item)"} | ||
| B --> |"PublishEvent(Output('***Hello, World***'))"| C[ConsoleAgent] | ||
| C --> D{"WriteConsole()"} | ||
| B --> |"PublishEvent(ConversationClosed('Goodbye'))"| E{"Handle(ConversationClosed item)"} | ||
| B --> |"PublishEvent(Output('***Goodbye***'))"| C | ||
| E --> F{"Shutdown()"} | ||
| ``` | ||
|
|
||
| ### Writing Event Handlers | ||
|
|
||
| The heart of an autogen application are the event handlers. Agents select a ```TopicSubscription``` to listen for events on a specific topic. When an event is received, the agent's event handler is called with the event data. | ||
|
|
||
| Within that event handler you may optionally *emit* new events, which are then sent to the event bus for other agents to process. The EventTypes are declared gRPC ProtoBuf messages that are used to define the schema of the event. The default protos are available via the ```Microsoft.AutoGen.Abstractions;``` namespace and are defined in [autogen/protos](/autogen/protos). The EventTypes are registered in the agent's constructor using the ```IHandle``` interface. | ||
|
|
||
| ```csharp | ||
| TopicSubscription("HelloAgents")] | ||
| public class HelloAgent( | ||
| IAgentContext context, | ||
| [FromKeyedServices("EventTypes")] EventTypes typeRegistry) : ConsoleAgent( | ||
| context, | ||
| typeRegistry), | ||
| ISayHello, | ||
| IHandle<NewMessageReceived>, | ||
| IHandle<ConversationClosed> | ||
| { | ||
| public async Task Handle(NewMessageReceived item) | ||
| { | ||
| var response = await SayHello(item.Message).ConfigureAwait(false); | ||
| var evt = new Output | ||
| { | ||
| Message = response | ||
| }.ToCloudEvent(this.AgentId.Key); | ||
| await PublishEvent(evt).ConfigureAwait(false); | ||
| var goodbye = new ConversationClosed | ||
| { | ||
| UserId = this.AgentId.Key, | ||
| UserMessage = "Goodbye" | ||
| }.ToCloudEvent(this.AgentId.Key); | ||
| await PublishEvent(goodbye).ConfigureAwait(false); | ||
| } | ||
| ``` | ||
|
|
||
| ### Inheritance and Composition | ||
|
|
||
| This sample also illustrates inheritance in AutoGen. The `HelloAgent` class inherits from `ConsoleAgent`, which is a base class that provides a `WriteConsole` method. | ||
|
|
||
| ### Starting the Application Runtime | ||
|
|
||
| AuotoGen provides a flexible runtime ```Microsoft.AutoGen.Agents.App``` that can be started in a variety of ways. The `Program.cs` file demonstrates how to start the runtime locally and send a message to the agent all in one go using the ```App.PublishMessageAsync``` method. | ||
|
|
||
| ```csharp | ||
| // send a message to the agent | ||
| var app = await App.PublishMessageAsync("HelloAgents", new NewMessageReceived | ||
| { | ||
| Message = "World" | ||
| }, local: true); | ||
|
|
||
| await App.RuntimeApp!.WaitForShutdownAsync(); | ||
| await app.WaitForShutdownAsync(); | ||
| ``` | ||
|
|
||
| ### Sending Messages | ||
|
|
||
| The set of possible Messages is defined in gRPC ProtoBuf specs. These are then turned into C# classes by the gRPC tools. You can define your own Message types by creating a new .proto file in your project and including the gRPC tools in your ```.csproj``` file: | ||
|
|
||
| ```proto | ||
| syntax = "proto3"; | ||
| package devteam; | ||
| option csharp_namespace = "DevTeam.Shared"; | ||
| message NewAsk { | ||
| string org = 1; | ||
| string repo = 2; | ||
| string ask = 3; | ||
| int64 issue_number = 4; | ||
| } | ||
| message ReadmeRequested { | ||
| string org = 1; | ||
| string repo = 2; | ||
| int64 issue_number = 3; | ||
| string ask = 4; | ||
| } | ||
| ``` | ||
|
|
||
| ```xml | ||
| <ItemGroup> | ||
| <PackageReference Include="Google.Protobuf" /> | ||
| <PackageReference Include="Grpc.Tools" PrivateAssets="All" /> | ||
| <Protobuf Include="..\Protos\messages.proto" Link="Protos\messages.proto" /> | ||
| </ItemGroup> | ||
| ``` | ||
|
|
||
| You can send messages using the [```Microsoft.AutoGen.Agents``` class](autogen/dotnet/src/Microsoft.AutoGen/Agents/AgentClient.cs). Messages are wrapped in [the CloudEvents specification](https://cloudevents.io) and sent to the event bus. | ||
| ### Managing State | ||
|
|
||
| There is a simple API for persisting agent state. | ||
|
|
||
| ```csharp | ||
| await Store(new AgentState | ||
| { | ||
| AgentId = this.AgentId, | ||
| TextData = entry | ||
| }).ConfigureAwait(false); | ||
| ``` | ||
|
|
||
| which can be read back using Read: | ||
|
|
||
| ```csharp | ||
| State = await Read<AgentState>(this.AgentId).ConfigureAwait(false); | ||
| ``` |
5 changes: 4 additions & 1 deletion
5
...rosoft.AutoGen/Abstractions/AgentState.cs → ...crosoft.AutoGen/Abstractions/ChatState.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.