Composio Notion integration guide

pip install openai>=1.0 composio-core composio-openai requests

import os
import json
import requests
from openai import OpenAI
from composio_openai import ComposioToolSet, Action

# Load environment variables
OPENAI_API_KEY = os.environ["OPENAI_API_KEY"]
COMPOSIO_API_KEY = os.environ["COMPOSIO_API_KEY"]
NOTION_TOKEN = os.environ["NOTION_TOKEN"]
NOTION_PAGE_ID = "your-notion-page-id"  # Replace with your Notion page ID

# Initialize OpenAI client
client = OpenAI(api_key=OPENAI_API_KEY)

# Initialize Composio toolset
toolset = ComposioToolSet(api_key=COMPOSIO_API_KEY)
tools = toolset.get_tools(actions=[Action.NOTION_READ_PAGE])

# Function to fetch Notion page content
def fetch_notion_page(page_id: str, token: str) -> str:
    url = f"https://api.notion.com/v1/blocks/{page_id}/children"
    headers = {
        "Authorization": f"Bearer {token}",
        "Notion-Version": "2022-06-28"
    }
    response = requests.get(url, headers=headers)
    response.raise_for_status()
    data = response.json()
    texts = []
    for block in data.get("results", []):
        if block["type"] == "paragraph":
            texts.append("".join([t["plain_text"] for t in block["paragraph"]["text"]]))
    return "\n".join(texts)

# Fetch Notion page text
notion_text = fetch_notion_page(NOTION_PAGE_ID, NOTION_TOKEN)

# Prepare messages with Notion context
messages = [
    {"role": "system", "content": "You are an AI assistant with access to Notion data."},
    {"role": "user", "content": f"Here is the Notion page content:\n{notion_text}\nPlease summarize it."}
]

# Call OpenAI chat completion with Composio tools
response = client.chat.completions.create(
    model="gpt-4o-mini",
    tools=tools,
    messages=messages
)

print("AI summary:", response.choices[0].message.content)

import asyncio
import httpx
from openai import OpenAI
from composio_openai import ComposioToolSet, Action

async def async_notion_integration():
    client = OpenAI(api_key=os.environ["OPENAI_API_KEY"])
    toolset = ComposioToolSet(api_key=os.environ["COMPOSIO_API_KEY"])
    tools = toolset.get_tools(actions=[Action.NOTION_READ_PAGE])

    async with httpx.AsyncClient() as http_client:
        # Async fetch Notion page omitted for brevity
        notion_text = "Async fetched Notion content"

    messages = [
        {"role": "system", "content": "You are an AI assistant with Notion access."},
        {"role": "user", "content": f"Summarize this:\n{notion_text}"}
    ]

    response = await client.chat.completions.create(
        model="gpt-4o",
        tools=tools,
        messages=messages
    )
    print("Async AI summary:", response.choices[0].message.content)

asyncio.run(async_notion_integration())