الخطوة 5: مهام سير العمل

تتيح لك مهام سير العمل تسلسل خطوات متعددة معا — تعالج كل خطوة البيانات وتمررها إلى الخطوة التالية.

تحديد خطوات سير العمل (المنفذون):

using Microsoft.Agents.AI.Workflows;

// Step 1: Convert text to uppercase
Func<string, string> uppercaseFunc = s => s.ToUpperInvariant();
var uppercase = uppercaseFunc.BindAsExecutor("UppercaseExecutor");

// Step 2: Reverse the string and yield output
class ReverseTextExecutor() : Executor<string, string>("ReverseTextExecutor")
{
    public override ValueTask<string> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
    {
        return ValueTask.FromResult(string.Concat(message.Reverse()));
    }
}
ReverseTextExecutor reverse = new();

إنشاء سير العمل وتشغيله:

WorkflowBuilder builder = new(uppercase);
builder.AddEdge(uppercase, reverse).WithOutputFrom(reverse);
var workflow = builder.Build();

await using Run run = await InProcessExecution.RunAsync(workflow, "Hello, World!");
foreach (WorkflowEvent evt in run.NewEvents)
{
    if (evt is ExecutorCompletedEvent executorComplete)
    {
        Console.WriteLine($"{executorComplete.ExecutorId}: {executorComplete.Data}");
    }
}

Tip

انظر هنا للحصول على نموذج تطبيق كامل قابل للتشغيل.

تحديد خطوات سير العمل (المنفذين) وتوصيلها بالحواف:

# Step 1: A class-based executor that converts text to uppercase
class UpperCase(Executor):
    def __init__(self, id: str):
        super().__init__(id=id)

    @handler
    async def to_upper_case(self, text: str, ctx: WorkflowContext[str]) -> None:
        """Convert input to uppercase and forward to the next node."""
        await ctx.send_message(text.upper())


# Step 2: A function-based executor that reverses the string and yields output
@executor(id="reverse_text")
async def reverse_text(text: str, ctx: WorkflowContext[Never, str]) -> None:
    """Reverse the string and yield the final workflow output."""
    await ctx.yield_output(text[::-1])


def create_workflow():
    """Build the workflow: UpperCase → reverse_text."""
    upper = UpperCase(id="upper_case")
    return WorkflowBuilder(start_executor=upper).add_edge(upper, reverse_text).build()

إنشاء سير العمل وتشغيله:

workflow = create_workflow()

events = await workflow.run("hello world")
print(f"Output: {events.get_outputs()}")
print(f"Final state: {events.get_final_state()}")

Tip

راجع النموذج الكامل للملف الكامل القابل للتشغيل.

تحديد خطوات سير العمل (المنفذين) وتوصيلها بالحواف:

package main

import (
    "context"
    "fmt"
    "slices"
    "strings"

    "github.com/microsoft/agent-framework-go/workflow"
    "github.com/microsoft/agent-framework-go/workflow/inproc"
)

func main() {
    // Step 1: Convert text to uppercase.
    uppercase := workflow.NewExecutor("UppercaseExecutor", func(input string) string {
        return strings.ToUpper(input)
    }).Bind()

    // Step 2: Reverse the string.
    reverse := workflow.NewExecutor("ReverseExecutor", func(input string) string {
        runes := []rune(input)
        slices.Reverse(runes)
        return string(runes)
    }).Bind()

    // Build the workflow by connecting executors sequentially.
    wf, err := workflow.NewBuilder(uppercase).
        AddEdge(uppercase, reverse).
        WithOutputFrom(reverse).
        Build()
    if err != nil {
        panic(err)
    }

    // Execute the workflow with sample input.
    run, err := inproc.Default.Run(context.Background(), wf, "Hello, World!")
    if err != nil {
        panic(err)
    }
    for evt := range run.NewEvents() {
        if evt, ok := evt.(workflow.ExecutorCompletedEvent); ok {
            fmt.Printf("%s: %v\n", evt.ExecutorID, evt.Result)
        }
    }
}

Tip

راجع النموذج الكامل للملف الكامل القابل للتشغيل.

الخطوات التالية

الخطوة 6: عامل Harness

انتقل إلى أبعد من ذلك:

• مهام سير العمل — فهم بنية سير العمل
• مهام سير العمل المتسلسلة — أنماط خطية خطوة بخطوة
• العوامل في مهام سير العمل — استخدام العوامل كخطوات سير عمل