CrewAI برای سازماندهی عوامل هوش مصنوعی مستقل طراحی شده است که برای دستیابی به اهداف پیچیده با یکدیگر همکاری می کنند. توسعه سیستمهای چند عاملی را سادهتر میکند و به شما این امکان را میدهد که عواملی با نقشها، اهداف و پیشینههای خاص تعریف کنید و سپس وظایفی را به آنها اختصاص دهید. این مثال نشان میدهد که چگونه میتوان یک سیستم چند عاملی را برای استفاده از یک افسر عملیاتی (COO) ساخت: تجزیه و تحلیل دادههای پشتیبانی مشتری برای شناسایی مشکلات و پیشنهاد بهبود فرآیند با استفاده از Gemini 2.5 Pro.
هدف ایجاد یک «خدمه» از عوامل هوش مصنوعی است که می توانند:
- داده های پشتیبانی مشتری را واکشی و تجزیه و تحلیل کنید (شبیه سازی شده در این مثال).
- مشکلات مکرر را شناسایی کنید و گلوگاه های فرآیند را شناسایی کنید.
- پیشنهاد بهبود عملی
- یافته ها را در یک گزارش مختصر و مناسب برای یک COO جمع آوری کنید.
اگر هنوز یک کلید API Gemini ندارید، میتوانید آن را به صورت رایگان در استودیوی هوش مصنوعی Google دریافت کنید.
pip install "crewai[tools]"
کلید Gemini API خود را به عنوان یک متغیر محیطی با نام GEMINI_API_KEY
تنظیم کنید. CrewAI را برای استفاده از مدل Gemini 2.5 Pro پیکربندی کنید.
import os
from crewai import LLM
# Read your API key from the environment variable
gemini_api_key = os.getenv("GEMINI_API_KEY")
if not gemini_api_key:
raise ValueError("GEMINI_API_KEY environment variable not set.")
# Use Gemini 2.5 Pro Experimental model
gemini_llm = LLM(
model='gemini/gemini-2.5-pro-preview-05-06',
api_key=gemini_api_key,
temperature=0.0 # Lower temperature for more factual analysis
)
تعریف مولفه ها
برنامههای CrewAI با استفاده از چندین مؤلفه کلیدی ساخته میشوند: ابزارها، عوامل، وظایف و خود خدمه.
ابزار
ابزارها قابلیت هایی هستند که عوامل می توانند از آنها برای تعامل با دنیای خارج یا انجام اقدامات خاص استفاده کنند. در اینجا، ما یک ابزار متغیر برای شبیهسازی واکشی دادههای پشتیبانی مشتری تعریف میکنیم. در یک برنامه واقعی، این می تواند به یک پایگاه داده، API یا سیستم فایل متصل شود.
from crewai.tools import BaseTool
# Placeholder Tool for fetching customer support data
class CustomerSupportDataTool(BaseTool):
name: str = "Customer Support Data Fetcher"
description: str = "Fetches recent customer support interactions, tickets, and feedback. Returns a summary string."
def _run(self, argument: str) -> str:
# In a real scenario, this would query a database or API.
# For this example, we return simulated data.
print(f"--- Fetching data for query: {argument} ---")
return (
"""Recent Support Data Summary:
- 50 tickets related to 'login issues'. High resolution time (avg 48h).
- 30 tickets about 'billing discrepancies'. Mostly resolved within 12h.
- 20 tickets on 'feature requests'. Often closed without resolution.
- Frequent feedback mentions 'confusing user interface' for password reset.
- High volume of calls related to 'account verification process'.
- Sentiment analysis shows growing frustration with 'login issues' resolution time.
- Support agent notes indicate difficulty reproducing 'login issues'."""
)
support_data_tool = CustomerSupportDataTool()
عوامل
عوامل، تک تک کارکنان هوش مصنوعی در خدمه شما هستند. هر عامل دارای role
، goal
، backstory
، llm
اختصاص یافته و tools
بالقوه خاصی است.
from crewai import Agent
# Agent 1: Data Analyst
data_analyst = Agent(
role='Customer Support Data Analyst',
goal='Analyze customer support data to identify trends, recurring issues, and key pain points.',
backstory=(
"""You are an expert data analyst specializing in customer support operations.
Your strength lies in identifying patterns and quantifying problems from raw support data."""
),
verbose=True,
allow_delegation=False, # This agent focuses on its specific task
tools=[support_data_tool], # Assign the data fetching tool
llm=gemini_llm # Use the configured Gemini LLM
)
# Agent 2: Process Optimizer
process_optimizer = Agent(
role='Process Optimization Specialist',
goal='Identify bottlenecks and inefficiencies in current support processes based on the data analysis. Propose actionable improvements.',
backstory=(
"""You are a specialist in optimizing business processes, particularly in customer support.
You excel at pinpointing root causes of delays and inefficiencies and suggesting concrete solutions."""
),
verbose=True,
allow_delegation=False,
# No specific tools needed, relies on the analysis context provided by the data_analyst
llm=gemini_llm
)
# Agent 3: Report Writer
report_writer = Agent(
role='Executive Report Writer',
goal='Compile the analysis and improvement suggestions into a concise, clear, and actionable report for the COO.',
backstory=(
"""You are a skilled writer adept at creating executive summaries and reports.
You focus on clarity, conciseness, and highlighting the most critical information and recommendations for senior leadership."""
),
verbose=True,
allow_delegation=False,
llm=gemini_llm
)
وظایف
وظایف، تکالیف خاص را برای عوامل تعریف می کند. هر وظیفه دارای description
, expected_output
, و به یک agent
اختصاص داده شده است . وظایف می تواند به خروجی کارهای قبلی بستگی داشته باشد.
from crewai import Task
# Task 1: Analyze Data
analysis_task = Task(
description=(
"""Fetch and analyze the latest customer support interaction data (tickets, feedback, call logs)
focusing on the last quarter. Identify the top 3-5 recurring issues, quantify their frequency
and impact (e.g., resolution time, customer sentiment). Use the Customer Support Data Fetcher tool."""
),
expected_output=(
"""A summary report detailing the key findings from the customer support data analysis, including:
- Top 3-5 recurring issues with frequency.
- Average resolution times for these issues.
- Key customer pain points mentioned in feedback.
- Any notable trends in sentiment or support agent observations."""
),
agent=data_analyst # Assign task to the data_analyst agent
)
# Task 2: Identify Bottlenecks and Suggest Improvements
optimization_task = Task(
description=(
"""Based on the data analysis report provided by the Data Analyst, identify the primary bottlenecks
in the support processes contributing to the identified issues (especially the top recurring ones).
Propose 2-3 concrete, actionable process improvements to address these bottlenecks.
Consider potential impact and ease of implementation."""
),
expected_output=(
"""A concise list identifying the main process bottlenecks (e.g., lack of documentation for agents,
complex escalation path, UI issues) linked to the key problems.
A list of 2-3 specific, actionable recommendations for process improvement
(e.g., update agent knowledge base, simplify password reset UI, implement proactive monitoring)."""
),
agent=process_optimizer # Assign task to the process_optimizer agent
# This task implicitly uses the output of analysis_task as context
)
# Task 3: Compile COO Report
report_task = Task(
description=(
"""Compile the findings from the Data Analyst and the recommendations from the Process Optimization Specialist
into a single, concise executive report for the COO. The report should clearly state:
1. The most critical customer support issues identified (with brief data points).
2. The key process bottlenecks causing these issues.
3. The recommended process improvements.
Ensure the report is easy to understand, focuses on actionable insights, and is formatted professionally."""
),
expected_output=(
"""A well-structured executive report (max 1 page) summarizing the critical support issues,
underlying process bottlenecks, and clear, actionable recommendations for the COO.
Use clear headings and bullet points."""
),
agent=report_writer # Assign task to the report_writer agent
)
خدمه
Crew
عوامل و وظایف را با هم جمع می کند و روند گردش کار را تعریف می کند (به عنوان مثال، متوالی).
from crewai import Crew, Process
# Define the crew with agents, tasks, and process
support_analysis_crew = Crew(
agents=[data_analyst, process_optimizer, report_writer],
tasks=[analysis_task, optimization_task, report_task],
process=Process.sequential, # Tasks will run sequentially in the order defined
verbose=True
)
اجرای خدمه
در نهایت، با هر ورودی لازم، اجرای خدمه را آغاز کنید.
# Start the crew's work
print("--- Starting Customer Support Analysis Crew ---")
# The 'inputs' dictionary provides initial context if needed by the first task.
# In this case, the tool simulates data fetching regardless of the input.
result = support_analysis_crew.kickoff(inputs={'data_query': 'last quarter support data'})
print("--- Crew Execution Finished ---")
print("--- Final Report for COO ---")
print(result)
اکنون اسکریپت اجرا خواهد شد. Data Analyst
از این ابزار استفاده می کند، Process Optimizer
یافته ها را تجزیه و تحلیل می کند و Report Writer
گزارش نهایی را جمع آوری می کند که سپس در کنسول چاپ می شود. تنظیمات verbose=True
فرآیند تفصیل فکر و اقدامات هر عامل را نشان می دهد.