MCP X402 Task Scheduler

🚀 TimeLooker MCP Serverとx402支払い統合

x402支払いを統合した自動検索監視機能を提供するモデルコンテキストプロトコル（MCP）サーバーです。検索クエリを監視し、AIによる重複検出を使用して新しいコンテンツを検出し、タスク作成の支払いを自動的に処理します。

🚀 クイックスタート

このシステムは、複数のコンポーネントが連携して動作します。以下にセットアップ手順や使用方法を説明します。

✨ 主な機能

• AIによる重複検出：OpenAIを使用して、本当に新しいアイテムと書式の違いを識別し、誤通知を大幅に削減します。
• x402支払い統合：タスク作成時の自動支払い処理をサポートし、その他の操作は無料で利用できます。
• 豊富な検索結果：ウェブ上の複数のソースからアイテムを検索し、タイトル、説明、URL、場所などを抽出します。
• 柔軟な監視：任意の検索クエリを設定でき、頻度と実行期間をカスタマイズできます。
• メール通知：新しいアイテムが見つかった場合に自動的に通知を送信し、アイテムの詳細を含む構造化されたメール形式で提供します。
• 完全な履歴追跡：各タスクの完全な実行履歴を追跡し、パフォーマンスメトリクスとエラートラッキングを行います。
• 堅牢なデータベース管理：自動スキーママイグレーションとバージョン追跡、データベースの整合性検証と孤立データの検出を行います。

📦 インストール

オプションA：ローカル開発環境のセットアップ

1. 依存関係のインストール

cd /path/to/MCP_Server
uv sync

2. 環境設定

サンプルの環境ファイルをコピーして設定します。

cp .env.example .env

.env ファイルを編集して設定を入力します。

# x402支払い設定
PAY_TO_ADDRESS=0x671cE47E4F38051ba3A990Ba306E2885C2Fe4102
PRIVATE_KEY=your_ethereum_private_key_here

# API設定
TASK_MANAGER_API_URL=http://localhost:8000

# OpenAI設定
OPENAI_API_KEY=your_openai_api_key_here

# データベース設定（オプション）
DATABASE_URL=sqlite:///timelooker.db

オプションB：AWSクラウドデプロイメント

1. 前提条件

• 適切な権限で構成されたAWS CLI
• AWS CDKのインストール: npm install -g aws-cdk
• Pythonの依存関係: uv sync

2. インフラストラクチャのデプロイ

# AWSインフラストラクチャ（RDS、Lambdaロール、SES、など）をデプロイ
python scripts/deploy_infrastructure.py

これにより、以下のリソースが作成されます。

• PostgreSQL RDSデータベース (db.t3.micro)
• メールテンプレート用のS3バケット
• APIキー用のAWS Secrets Manager
• Lambda実行用のIAMロール
• SESメールID

3. シークレットの設定

デプロイ後、AWS Secrets Managerのシークレットを更新します。

# OpenAI APIキーを更新
aws secretsmanager update-secret \
  --secret-id "timelooker/openai/api-key" \
  --secret-string '{"api_key":"your_openai_key_here"}'

# X402秘密鍵を更新
aws secretsmanager update-secret \
  --secret-id "timelooker/x402/private-key" \
  --secret-string '{"private_key":"your_private_key_here"}'

4. SESメールの検証

AWSコンソール > SES > 検証済みIDにアクセスし、送信元メールアドレスを検証します。

5. 環境設定

デプロイスクリプトにより、インフラストラクチャの詳細が記載された .env.aws ファイルが作成されます。これを更新して値を入力します。

cp .env.aws .env
# .envを編集して秘密鍵と送信元メールアドレスを追加

6. シークレット統合のテスト

システムがAWSからシークレットを取得できることを確認します。

# シークレットの取得をテスト
python scripts/test_secrets.py

これにより、システムがAWS Secrets Managerからデータベースの資格情報、APIキー、その他のシークレットを自動的に取得できるかどうかが表示されます。

3. データベース管理

データベースの初期化

# 基本的な初期化
python scripts/init_db.py

# サンプルデータで初期化
python scripts/init_db.py --sample

データベース操作

# スキーマバージョンを確認
python scripts/init_db.py --version

# データベースの整合性を検証
python scripts/init_db.py --validate

# データベースマイグレーションを実行
python scripts/init_db.py --migrate

# データベースをリセット（削除して再作成）
python scripts/init_db.py --reset

# リセットしてサンプルデータを作成
python scripts/init_db.py --reset --sample

4. APIサーバーの起動

python run_api_server.py
# または
uv run run_api_server.py

5. Claude Desktopの設定

Claude Desktopの設定ファイルを編集します。

• macOS: ~/Library/Application Support/Claude/claude_desktop_config.json
• Windows: %APPDATA%\Claude\claude_desktop_config.json

デプロイモードに応じて適切な設定を選択します。

ローカル開発用:

cp claude_desktop_config_local.json ~/Library/Application\ Support/Claude/claude_desktop_config.json

AWSクラウドデプロイ用:

cp claude_desktop_config_cloud.json ~/Library/Application\ Support/Claude/claude_desktop_config.json
# 次に、ファイルを編集してYOUR_ACCOUNTとエンドポイントの値をデプロイ時の実際の値に置き換えます

手動設定:

claude_config_example.json の内容を手動でコピーし、自分の値を追加することもできます。

重要: /absolute/path/to/MCP_Server を実際の絶対パスに置き換えてください！

6. Claude Desktopの再起動

設定を編集した後、Claude Desktopを完全に再起動します。

💻 使用例

設定が完了したら、Claude Desktopで自然言語を使用して操作できます。

タスクの作成（支払いが必要）

• "次の1週間、新しいiPhoneのリリースを2時間ごとに監視する検索タスクを作成して"
• "「リモートPythonの仕事」を5分ごとに1時間間隔でチェックする監視を設定して"
• "AIセキュリティの研究論文を2週間、毎日チェックする"

タスクの管理（無料）

• "すべてのアクティブな検索タスクを表示して"
• "最初の検索タスクのステータスを教えて"
• "タスク2の検索を実行して"
• "iPhoneの監視タスクを削除して"

プレビュー（無料）

• "2025年の機械学習会議の検索結果をプレビューして"
• "暗号通貨のニュースを監視した場合の結果を表示して"

📚 ドキュメント

MCPツールの利用可能な機能

MCPサーバーは、Claude Desktop用の6つの強力なツールを提供します。

create_search_task（支払いが必要）

任意の検索クエリに対する自動監視タスクを作成します。

• 支払い: タスク作成ごとに$1.00
• パラメータ: クエリ、頻度（最小1分）、メール、実行時間、送信元メール
• クラウドモード: 自動的にLambda関数とEventBridgeスケジュールをデプロイします。
• ローカルモード: 手動実行用にデータベースにタスクを作成します。
• 例: "次の3日間、AI倫理の求人を1時間ごとに監視する検索タスクを作成して"

execute_search（無料）

既存のタスクの検索を実行し、新しい結果を取得します。

• パラメータ: タスクID
• 例: "タスク1の検索を実行して"

list_search_tasks（無料）

すべてのアクティブな監視タスクを表示します。

• 例: "すべての検索タスクを表示して"

get_task_status（無料）

タスクの詳細なステータスと実行履歴を取得します。

• パラメータ: タスクID、最近の実行回数を表示する数
• 例: "タスク2のステータスはどうですか？"

delete_search_task（無料）

監視タスクを非アクティブ化します。

• パラメータ: タスクID
• 例: "タスク3を削除して"

search_preview（無料）

タスクを作成せずに検索結果をプレビューします。

• パラメータ: クエリ、最大結果数
• 例: "「Python開発者のリモートの仕事」の検索結果をプレビューして"

APIエンドポイント

FastAPIサーバーは以下のエンドポイントを提供します。

• POST /tasks/ - タスクを作成する（支払いが必要）
• GET /tasks/ - アクティブなタスクを一覧表示する
• GET /tasks/{task_id} - タスクの詳細を取得する
• DELETE /tasks/{task_id} - タスクを非アクティブ化する
• POST /executions/ - 実行レコードを作成する
• PUT /executions/{execution_id} - 実行を更新する
• GET /tasks/{task_id}/should-run - タスクを実行する必要があるかどうかを確認する
• POST /tasks/{task_id}/results - 検索結果を保存する
• GET /tasks/{task_id}/results - 以前の結果を取得する
• POST /tasks/{task_id}/notify - メール通知を送信する

🔧 技術詳細

アーキテクチャの概要

システムは、複数のコンポーネントが連携して動作します。

コアコンポーネント

• src/api/task_manager_api.py - x402支払いミドルウェアを備えたFastAPIサービス
• src/api/task_manager_client.py - x402支払いをサポートするHTTPクライアント
• src/mcp/searcher_mcp.py - Claude Desktopにツールを公開するMCPサーバー
• src/core/search_engine.py - ウェブ検索の実行とAIによる比較
• src/core/task_manager.py - データベース操作とタスク管理
• src/core/models.py - SQLAlchemyのデータベースモデル

支払い統合

• x402プロトコル - タスク作成時の自動支払い（タスクごとに$1.00）
• 支払いアドレス - 0x671cE47E4F38051ba3A990Ba306E2885C2Fe4102
• ネットワーク - base-sepolia
• 無料エンドポイント - タスク作成を除くすべての操作

デプロイメントオプション

ローカル開発モード

• セットアップ: ローカルデータベース（SQLite）を使用した .env を使用します。
• タスク実行: MCPツールまたはスケジュールされたスクリプトを介して手動で実行します。
• APIサーバー: python run_api_server.py でローカルで実行します。
• MCPサーバー: python run_mcp_server.py でローカルで実行します。
• データベース: SQLiteファイル
• 支払い: 依然としてx402を介して処理されます。

AWSクラウドモード

• セットアップ: DEPLOY_TO_CLOUD=true を設定した .env を使用します。
• タスク実行: Lambda関数とEventBridgeを介して自動的に実行します。
• インフラストラクチャ: RDS PostgreSQL、Lambda関数、SES、S3
• スケーリング: サーバーレスで、複数のタスクを自動的に処理します。
• コスト: 通常の使用で月約$15 - 30
• 利点:
  • 手動でのタスク実行が不要
  • 実行時間が経過した後の自動クリーンアップ
  • SESを介したプロフェッショナルなメールテンプレート
  • スケーラブルで耐障害性が高い

ハイブリッドモード

• APIサーバー: クラウドデータベースを使用したローカル開発
• タスク作成: 実行用のLambda関数を作成します。
• 最適なシナリオ: 本番環境のインフラストラクチャを使用しながら開発する場合

自動化オプション

オプション1: Cronジョブ

# 5分ごとにチェックし、実行可能なタスクを実行
*/5 * * * * cd /path/to/MCP_Server && python scripts/run_scheduled_tasks.py

オプション2: バックグラウンドサービス

# 連続して実行し、60秒ごとにチェック
python scripts/run_scheduled_tasks.py --daemon --interval 60

📄 ライセンス

原文書にライセンス情報は記載されていません。