Composio 完全ガイド：AI エージェントに 1000 以上のツール能力を与えるオープンソースフレームワーク

# pip を使用
pip install composio

# または poetry を使用
poetry add composio

pip install composio_openai_agents openai-agents

# npm を使用
npm install @composio/core

# yarn を使用
yarn add @composio/core

# pnpm を使用
pnpm add @composio/core

npm install @composio/openai-agents @openai/agents

export COMPOSIO_API_KEY="your-api-key-here"

import asyncio
from agents import Agent, Runner
from composio import Composio
from composio_openai_agents import OpenAIAgentsProvider

# Composio クライアントを初期化
composio = Composio(provider=OpenAIAgentsProvider())

# ユーザー ID を取得（認証の分離用）
user_id = "user@example.com"

# Hacker News ツールを取得
tools = composio.tools.get(
    user_id=user_id,
    toolkits=["HACKERNEWS"]
)

# エージェントを作成
agent = Agent(
    name="HackerNews Agent",
    instructions="あなたは Hacker News のアシスタントで、最新の技術動向を知る手助けをします。",
    tools=tools,
)

# エージェントを実行
async def main():
    result = await Runner.run(
        starting_agent=agent,
        input="今日 Hacker News で最も注目を集めている技術スレッドは何？",
    )
    print(result.final_output)

asyncio.run(main())

import { Composio } from '@composio/core';
import { OpenAIAgentsProvider } from '@composio/openai-agents';
import { Agent, run } from '@openai/agents';

// SDK を初期化
const composio = new Composio({
  provider: new OpenAIAgentsProvider(),
});

const userId = 'user@example.com';

// ツールを取得
const tools = await composio.tools.get(userId, {
  toolkits: ['HACKERNEWS'],
});

// エージェントを作成
const agent = new Agent({
  name: 'HackerNews assistant',
  tools: tools,
});

// 実行
const result = await run(agent, 'What is the latest hackernews post about?');
console.log(JSON.stringify(result.finalOutput, null, 2));

from composio import Composio
from composio_openai_agents import OpenAIAgentsProvider

# 初期化
composio = Composio(provider=OpenAIAgentsProvider())
user_id = "dev-team@company.com"

# 複数のツールキットを取得
tools = composio.tools.get(
    user_id=user_id,
    toolkits=["GITHUB", "SLACK"],
)

# DevOps エージェントを作成
agent = Agent(
    name="DevOps Assistant",
    instructions="""
    あなたは DevOps アシスタントで、以下のことができます：
    1. GitHub リポジトリの Issue 状態を確認
    2. 新しい Issue や Pull Request を作成
    3. Slack チャンネルに通知を送信

    重要な Issue の更新があれば、自動的にチームに通知してください。
    """,
    tools=tools,
)

async def monitor_issues():
    """重要な Issue を監視しチームに通知"""
    result = await Runner.run(
        starting_agent=agent,
        input="""
        composiohq/composio リポジトリで 'bug' ラベルが付いており、7 日以上返信がない Issue を確認し、
        そのリストを #engineering Slack チャンネルに送信してください。
        """,
    )
    print(result.final_output)

# 認証フローを開始するにはコード 1 行だけ
connection = composio.connections.initiate(
    user_id=user_id,
    app_name="gmail",
)
# ユーザーが OAuth 承認を完了すると、Composio がトークンを自動管理

from composio_langchain import ComposioToolSet

toolset = ComposioToolSet()
tools = toolset.get_tools(apps=["github", "slack"])

from langchain.agents import initialize_agent
agent = initialize_agent(
    tools=tools,
    llm=your_llm,
    agent_type="zero-shot-react-description"
)

from crewai import Agent, Task, Crew
from composio_crewai import ComposioToolSet

toolset = ComposioToolSet()
github_tools = toolset.get_tools(apps=["github"])

researcher = Agent(
    role='GitHub Researcher',
    goal='GitHub のトレンドプロジェクトを分析',
    tools=github_tools,
    backstory='あなたはオープンソースプロジェクトのアナリストです',
)

from composio_autogen import ComposioToolSet

toolset = ComposioToolSet()
tools = toolset.get_tools(apps=["notion", "gmail"])

# ツールを AutoGen エージェントに渡す
assistant = ConversableAgent(
    "assistant",
    llm_config={"config_list": config_list},
    function_map=tools.get_function_map(),
)

from composio import Composio
from composio_openai_agents import OpenAIAgentsProvider

# 初期化
composio = Composio(provider=OpenAIAgentsProvider())
user_id = "support-bot@company.com"

# カスタマーサポート関連ツールを取得
tools = composio.tools.get(
    user_id=user_id,
    toolkits=["NOTION", "JIRA", "GMAIL"],
)

# カスタマーサポートエージェントを作成
support_agent = Agent(
    name="Customer Support Agent",
    instructions="""
    あなたは会社のインテリジェントカスタマーサポートアシスタントです。ワークフロー：

    1. まず Notion ナレッジベースでユーザーの質問に対する答えを検索
    2. 答えが見つかった場合、Gmail でユーザーに送信
    3. 答えが見つからない場合、Jira でサポートチケットを作成し、
       テクニカルサポートチームに割り当て、Gmail でユーザーにチケット番号を通知

    友好的でプロフェッショナルな口調を保ってください。
    """,
    tools=tools,
)

# ユーザーの問い合わせを処理
async def handle_customer_query(customer_email: str, question: str):
    prompt = f"""
    顧客メール：{customer_email}
    質問：{question}

    ワークフローに従って処理してください。
    """

    result = await Runner.run(
        starting_agent=support_agent,
        input=prompt,
    )
    return result.final_output

# 複数のデータソースを同時に照会
tools = composio.tools.get(
    user_id=user_id,
    toolkits=["GITHUB", "GITLAB", "BITBUCKET"],
)
# エージェントは 3 つのプラットフォームのプロジェクト情報を並列で照会可能

tools = composio.tools.get(
    user_id=user_id,
    toolkits=["HACKERNEWS"],
    cache_ttl=300,  # 5 分間キャッシュ
)

# 開発シナリオ：コード関連ツールのみ読み込み
dev_tools = composio.tools.get(user_id, toolkits=["GITHUB", "GITLAB"])

# オフィスシナリオ：生産性ツールのみ読み込み
office_tools = composio.tools.get(user_id, toolkits=["GMAIL", "NOTION", "SLACK"])

try:
    result = await Runner.run(agent, input)
except ToolExecutionError as e:
    print(f"ツール実行失敗: {e}")
    # フォールバック戦略：代替ツールを使用するか、親切なメッセージを返す