ワークフローの並行処理

direction: down

Input: {
  label: "製品説明"
  shape: oval
}

Parallel-Processing: {
  label: "並列処理"
  style.stroke-dash: 2

  Feature-Extractor: {
    label: "特徴抽出 Agent\n(Agent 1)"
  }

  Audience-Analyzer: {
    label: "オーディエンス分析 Agent\n(Agent 2)"
  }
}

Aggregator: {
  label: "アグリゲーター"
}

Result: {
  label: "統合結果"
  shape: oval
}

Input -> Parallel-Processing.Feature-Extractor: "特徴を分析"
Input -> Parallel-Processing.Audience-Analyzer: "オーディエンスを分析"
Parallel-Processing.Feature-Extractor -> Aggregator: "特徴の要約"
Parallel-Processing.Audience-Analyzer -> Aggregator: "オーディエンスのプロファイル"
Aggregator -> Result

git clone https://github.com/AIGNE-io/aigne-framework

cd aigne-framework/examples/workflow-concurrency
pnpm install

import { AIAgent, AIGNE, ProcessMode, TeamAgent } from "@aigne/core";
import { OpenAIChatModel } from "@aigne/core/models/openai-chat-model.js";

const { OPENAI_API_KEY } = process.env;

// AI モデルを初期化する
const model = new OpenAIChatModel({
  apiKey: OPENAI_API_KEY,
});

// 製品の特徴を抽出する最初の Agent を定義する
const featureExtractor = AIAgent.from({
  instructions: `\
You are a product analyst. Extract and summarize the key features of the product.\n\nProduct description:\n{{product}}`,
  outputKey: "features",
});

// ターゲットオーディエンスを分析する2番目の Agent を定義する
const audienceAnalyzer = AIAgent.from({
  instructions: `\
You are a market researcher. Identify the target audience for the product.\n\nProduct description:\n{{product}}`,
  outputKey: "audience",
});

// AIGNE インスタンスを初期化する
const aigne = new AIGNE({ model });

// 並列ワークフローを管理するために TeamAgent を作成する
const teamAgent = TeamAgent.from({
  skills: [featureExtractor, audienceAnalyzer],
  mode: ProcessMode.parallel,
});

// 製品説明でチームを呼び出す
const result = await aigne.invoke(teamAgent, {
  product: "AIGNE is a No-code Generative AI Apps Engine",
});

console.log(result);

/*
期待される出力:
{
  features: "**Product Name:** AIGNE\n\n**Product Type:** No-code Generative AI Apps Engine\n\n...",
  audience: "**Small to Medium Enterprises (SMEs)**: \n   - Businesses that may not have extensive IT resources or budget for app development but are looking to leverage AI to enhance their operations or customer engagement.\n\n...",
}
*/

aigne observe