CrewAI tutorial

pip install crewai
pip install 'crewai[tools]'  # Pro pokročilé nástroje

import os
from crewai import Agent, Task, Crew
from crewai_tools import SerperDevTool, ScrapeWebsiteTool

# Nastavení API klíčů
os.environ["OPENAI_API_KEY"] = "your-openai-api-key"
os.environ["SERPER_API_KEY"] = "your-serper-api-key"  # Pro web search

search_tool = SerperDevTool()
scrape_tool = ScrapeWebsiteTool()

researcher = Agent(
    role='Senior Research Analyst',
    goal='Najít a analyzovat nejnovější trendy v AI a machine learningu',
    backstory="""Jsi zkušený research analytik s 10letou praxí 
    v oblasti AI. Specializuješ se na identifikaci emerging technologií 
    a jejich potenciálního dopadu na byznys.""",
    verbose=True,
    allow_delegation=False,
    tools=[search_tool, scrape_tool],
    max_iter=3,
    memory=True
)

research_task = Task(
    description="""Proveď comprehensive research o současných trendech 
    v oblasti Large Language Models. Zaměř se na:
    1. Nejnovější modely vydané v posledních 6 měsících
    2. Klíčové inovace v architektuře
    3. Praktické aplikace v enterprise prostředí
    4. Predikce budoucího vývoje""",
    
    expected_output="""Strukturovaná zpráva s následujícími sekcemi:
    - Executive Summary (2-3 odstavce)
    - Analýza nových modelů (seznam s popisem)
    - Technické inovace (klíčové body)
    - Business aplikace (konkrétní use cases)
    - Budoucí trendy (predikce na 12 měsíců)""",
    
    agent=researcher,
    tools=[search_tool, scrape_tool]
)

# Content Strategist
strategist = Agent(
    role='Content Marketing Strategist',
    goal='Vytvořit efektivní content strategy založenou na research datech',
    backstory="""Jsi expert na content marketing s deep understandingem 
    SEO a audience engagement. Umíš transformovat research data 
    do actionable content strategie.""",
    verbose=True,
    allow_delegation=True,
    tools=[search_tool]
)

# Content Writer  
writer = Agent(
    role='Senior Technical Writer',
    goal='Napsat engaging a technicky přesný obsah',
    backstory="""Jsi zkušený technical writer specializující se na AI 
    a software development. Umíš complex technické koncepty 
    prezentovat srozumitelně pro různé audience.""",
    verbose=True,
    allow_delegation=False
)

# Editor
editor = Agent(
    role='Content Editor',
    goal='Zajistit nejvyšší kvalitu a konzistenci obsahu',
    backstory="""Jsi detail-oriented editor s okem pro kvalitu. 
    Specializuješ se na tech content a zajišťuješ, že každý piece 
    splňuje editorial standards.""",
    verbose=True,
    allow_delegation=False
)

# 1. Research task
research_task = Task(
    description="Proveď research o CrewAI frameworku a jeho competitive landscape",
    expected_output="Detailní research report s competitive analysis",
    agent=researcher
)

# 2. Strategy task (závislý na research)
strategy_task = Task(
    description="""Na základě research dat vytvoř content strategy pro 
    CrewAI tutorial sérii. Definuj:
    - Target audience segments
    - Content topics a priority
    - Distribution channels
    - Success metrics""",
    expected_output="Comprehensive content strategy document",
    agent=strategist,
    context=[research_task]  # Závislost na research task
)

# 3. Writing task
writing_task = Task(
    description="""Napiš úvodní tutorial článek o CrewAI podle 
    content strategy. Článek by měl být:
    - 1200-1500 slov
    - Prakticky zaměřený s code examples
    - Optimalizovaný pro SEO""",
    expected_output="Hotový tutorial článek v markdown formátu",
    agent=writer,
    context=[research_task, strategy_task]
)

# 4. Editing task
editing_task = Task(
    description="""Proveď final edit článku. Zkontroluj:
    - Gramatiku a stylistiku
    - Technickou přesnost
    - SEO optimalizaci
    - Strukturu a flow""",
    expected_output="Finální, publikace-ready článek",
    agent=editor,
    context=[writing_task]
)

# Vytvoření crew
content_crew = Crew(
    agents=[researcher, strategist, writer, editor],
    tasks=[research_task, strategy_task, writing_task, editing_task],
    verbose=2,  # Úroveň detailního logování
    process=Process.sequential,  # Sekvenční zpracování
    memory=True,  # Povolení paměti mezi tasky
    max_rpm=10,  # Rate limiting
    share_crew=False
)

# Spuštění workflow
try:
    result = content_crew.kickoff()
    print("Workflow completed successfully!")
    print(f"Final result: {result}")
    
except Exception as e:
    print(f"Error during execution: {e}")
    # Logging a error handling

from crewai_tools import BaseTool

class DatabaseQueryTool(BaseTool):
    name: str = "Database Query Tool"
    description: str = "Umožňuje dotazovat se do firemní databáze"
    
    def _run(self, query: str) -> str:
        # Implementace databázového dotazu
        # connection = get_db_connection()
        # result = connection.execute(query)
        return f"Query result for: {query}"

# Použití custom tool
db_tool = DatabaseQueryTool()
analyst = Agent(
    role='Data Analyst',
    goal='Analyzovat business data',
    tools=[db_tool],
    # ... další parametry
)

manager = Agent(
    role='Project Manager',
    goal='Koordinovat práci týmu a zajistit dodržení deadlinů',
    backstory='Zkušený PM s expertise v AI projektech',
    allow_delegation=True,
    verbose=True
)

hierarchical_crew = Crew(
    agents=[manager, researcher, writer, editor],
    tasks=[research_task, writing_task, editing_task],
    process=Process.hierarchical,
    manager_llm="gpt-4",  # Specializovaný LLM pro managera
    verbose=2
)