AgentScope - Điều Hợn Nhiệm Vụ và Triển Khai

Tổng Quan: 6 Mô Hình Điều Hợn Nhiệm Vụ Chính Của AgentScope

1. Thực Thi Tuần Tự (Sequential): Hoàn thành bước trước rồi mới đến bước sau
2. Thực Thi Song Song (Parallel): Nhiều nhiệm vụ chạy đồng thời
3. Nhánh Điều Kiện (Conditional): Định tuyến theo điều kiện
4. Lập Kế Hoạch + Tự Động Điều Hợn (Plan & Execute): Agent tự phân chia nhiệm vụ
5. Hợp Tác Chủ-Tớ (Coordinator-Worker): Quản lý + Thực thi
6. Điều Hợn Dòng Chảy (Pipeline): Xử lý đa giai đoạn theo luồng (Cấp doanh nghiệp)

Dưới đây là giải thích chi tiết từng mô hình + ví dụ code có thể chạy.

1. Thực Thi Tuần Tự (Sequential) ===================

Tình Huống Sử Dụng

• Nhiệm vụ có thứ tự ưu tiên
• Kết quả bước trước là đầu vào cho bước sau
• Quy trình cố định: trích xuất → làm sạch → phân tích → báo cáo

Ví Dụ Code

from agentscope.agents import AgentBase, ReasoningAgent
from agentscope.pipeline import SequentialPipeline

# 1. Tạo nhiều agent có chuyên môn
data_extractor = ReasoningAgent(name="Trích Xuất", sys_prompt="Trích xuất từ khóa từ văn bản")
data_analyzer = ReasoningAgent(name="Phân Tích", sys_prompt="Phân tích cảm xúc văn bản")
report_generator = ReasoningAgent(name="Báo Cáo", sys_prompt="Tạo báo cáo tổng hợp")

# 2. Điều hòa tuần tự: thực thi theo thứ tự
pipeline = SequentialPipeline(
    agents=[data_extractor, data_analyzer, report_generator]
)

# 3. Thực thi
result = pipeline.run("Sự kiện ra mắt sản phẩm hôm nay thành công rực rỡ, phản hồi người dùng tích cực")
print(result)

Luồng Thực Thi

Đầu vào người dùng → Trích xuất → Phân tích → Báo cáo → Đầu ra

2. Thực Thi Song Song (Parallel) =================

Tình Huống Sử Dụng

• Nhiều nhiệm vụ độc lập chạy đồng thời
• Kiểm tra thời tiết + tra cứu chứng khoán + cập nhật tin tức
• Tăng tốc độ thực thi, giảm thời gian tổng

Ví Dụ Code

from agentscope.pipeline import ParallelPipeline

# 1. Tạo nhiều agent độc lập
weather_agent = ReasoningAgent(name="Trợ Lý Thời Tiết", sys_prompt="Cung cấp thông tin thời tiết")
stock_agent = ReasoningAgent(name="Trợ Lý Chứng Khoán", sys_prompt="Theo dõi giá cổ phiếu")
news_agent = ReasoningAgent(name="Trợ Lý Tin Tức", sys_prompt="Cập nhật tin tức nóng")

# 2. Điều hòa song song
parallel = ParallelPipeline(agents=[weather_agent, stock_agent, news_agent])

# 3. Thực thi (ba tác vụ cùng lúc)
results = parallel.run("Thời tiết Hà Nội hôm nay, giá cổ phiếu Vingroup, tin tức công nghệ mới nhất")

Đặc Điểm

• Thực thi đồng thời, không chờ đ nhau
• Tổng hợp kết quả từ tất cả agent

3. Điều Hợn Có Điều Kiện (Conditional) ======================

Tình Huống Sử Dụng

• Nếu người dùng hỏi về thời tiết → chuyển đến agent thời tiết
• Nếu người dùng hỏi về code → chuyển đến agent lập trình
• Định tuyến nhiệm vụ động

Ví Dụ Code

from agentscope.pipeline import ConditionalPipeline

# Định nghĩa quy tắc định tuyến
def determine_route(message: str) -> str:
    if "thời tiết" in message:
        return "weather"
    elif "code" in message or "lập trình" in message:
        return "code"
    else:
        return "general"

# Điều hòa
conditional = ConditionalPipeline(
    router=determine_route,
    agents={
        "weather": ReasoningAgent(name="Chuyên Gia Thời Tiết"),
        "code": ReasoningAgent(name="Chuyên Gia Lập Trình"),
        "general": ReasoningAgent(name="Trợ Lý Tổng Quát")
    }
)

# Thực thi
conditional.run("Viết giúp tôi một thuật toán sắp xếp chèn bằng Python")

Luồng Thực Thi

Câu hỏi người dùng → Phán định điều kiện → Chuyển đến agent phù hợp → Trả về kết quả

4. Lập Kế Hoạch + Tự Động Điều Hợn (Plan & Execute) ==================================

Tình Huống Sử Dụng

• Nhiệm vụ phức tạp: Agent tự chia nhỏ thành các bước
• Tự động điều hòa: không cần viết quy trình thủ công
• Ví dụ: viết báo cáo, phân tích dữ liệu, đề xuất dự án

Đây là mô hình điều hòa mạnh mẽ nhất của AgentScope

Ví Dụ Code

from agentscope.agents import PlanningAgent

# Tự động lập kế hoạch + điều hòa + thực thi
agent = PlanningAgent(name="Chuyên Gia Chiến Lược")

# Nhiệm vụ phức tạp
agent.run(
    "Xây dựng kế hoạch tiếp thị sản phẩm AI năm 2025, bao gồm phân tích thị trường, phân khúc khách hàng, kênh truyền thông, ngân sách và lộ trình"
)

Quy Trình Tự Động Thực Thi (Không nhìn thấy nhưng framework đang thực hiện)

1. Hiểu nhiệm vụ
2. Tạo các bước:

• Phân tích thị trường
• Xác định khách hàng mục tiêu
• Chiến lược kênh
• Lập ngân sách
• Lập timeline

3. Tự động gọi agent chuyên môn

4. Tự động điều hòa thứ tự thực thi

5. Tạo báo cáo cuối cùng

6. Điều Hợn Hợp Tác Chủ-Tớ (Coordinator + Worker) ===============================

Tình Huống Sử Dụng

• Hệ thống đa agent cấp doanh nghiệp
• Một quản lý (Coordinator)
• Nhiều chuyên gia thực thi (Worker)
• Quản lý phân công nhiệm vụ → Worker thực thi → Quản lý tổng hợp kết quả

Ví Dụ Code

from agentscope.agents import ManagerAgent, SpecialistAgent

# Chuyên gia (năng lực chuyên môn)
content_specialist = SpecialistAgent(name="Chuyên Gia Nội Dung")
design_specialist = SpecialistAgent(name="Chuyên Gia Thiết Kế")
marketing_specialist = SpecialistAgent(name="Chuyên Gia Marketing")

# Quản lý (phân công công việc)
project_manager = ManagerAgent(
    name="Quản Lý Dự Án",
    specialists=[content_specialist, design_specialist, marketing_specialist]
)

# Quản lý tự động phân công công việc
project_manager.run("Triển khai chiến dịch quảng cáo Black Friday cho sắm trực tuyến")

Luồng Thực Thi

Quản lý → Phân chia công việc → Gửi cho nội dung/thiết kế/marketing → Thu thập kết quả → Tổng hợp đầu ra

6. Điều Hợn Dòng Chảy (Pipeline - Phổ Biến Nhất Cấp Doanh Nghiệp) =========================

Tình Huống Sử Dụng

• Quy trình đa giai đoạn, tái sử dụng được, cấp sản xuất
• Làm sạch dữ liệu → Trích xuất đặc trưng → Dự đoán mô hình → Xuất báo cáo
• Hỗ trợ: tuần tự, song song, nhánh, lồng ghép

Ví Dụ Code (Tiêu Chuẩn)

from agentscope.pipeline import Pipeline
from agentscope.pipeline import Stage, StartStage, EndStage

# 1. Định nghĩa giai đoạn
start = StartStage()
extract_stage = Stage(ReasoningAgent(name="Trích Xuất"))
analyze_stage = Stage(ReasoningAgent(name="Phân Tích"))
report_stage = Stage(ReasoningAgent(name="Báo Cáo"))
end = EndStage()

# 2. Xây dựng dòng chảy
workflow = Pipeline()
workflow.add_connection(start, extract_stage)
workflow.add_connection(extract_stage, analyze_stage)
workflow.add_connection(analyze_stage, report_stage)
workflow.add_connection(report_stage, end)

# 3. Thực thi
workflow.run("Yêu cầu xử lý văn bản của người dùng")

Ưu Điểm

• Trực quan hóa
• Có thể lồng ghép
• Có thể cập nhật nóng
• Có thể thực thi phân tán
• Cách làm tiêu chuẩn trong môi trường sản xuất doanh nghiệp

Quan Trọng Nhất: Lựa Chọn 6 Phương Thức Điều Hợn？（Tổng Kết Chiến Lược）

Tổng Kết Cuối Cùng (Nắm Vững 4 Điểm Này)

1. Nhiệm vụ đơn giản dùng Tuần tự/Song song
2. Nhiệm vụ định tuyến dùng Điều kiện
3. Nhiệm vụ phức tạp dùng Điều hòa tự động (Agent tự điều hòa)
4. Hệ thống doanh nghiệp dùng Chủ-tớ / Dòng chảy