Bright Data MCPを基にしたAI Telegramデータ抽出ロボット

上級

これはEngineering, Building Blocks, AI分野の自動化ワークフローで、21個のノードを含みます。主にIf, N8n, Wait, Webhook, Telegramなどのノードを使用、AI技術を活用したスマート自動化を実現。 Bright Data MCP の統合を备えた AI Telegram データ抽出ボット

前提条件
  • HTTP Webhookエンドポイント(n8nが自動生成)
  • Telegram Bot Token
  • ターゲットAPIの認証情報が必要な場合あり
ワークフロープレビュー
ノード接続関係を可視化、ズームとパンをサポート
ワークフローをエクスポート
以下のJSON設定をn8nにインポートして、このワークフローを使用できます
{
  "meta": {
    "instanceId": "4e6be3a68285934388a854ac0ffdc5e5500688d5cdb88d0ec2d734e85f097355",
    "templateCredsSetupCompleted": true
  },
  "nodes": [
    {
      "id": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
      "name": "AIエージェント",
      "type": "@n8n/n8n-nodes-langchain.agent",
      "position": [
        -1580,
        840
      ],
      "parameters": {
        "text": "={{ $json.body.message.text }}",
        "options": {
          "systemMessage": "You are a helpful assistant. Run the MCP tool when dealing with the web search, scraping, and browser automation."
        },
        "promptType": "define"
      },
      "typeVersion": 1.9
    },
    {
      "id": "860579ca-110e-4b7d-848a-e4085e05a6a6",
      "name": "シンプルメモリ",
      "type": "@n8n/n8n-nodes-langchain.memoryBufferWindow",
      "position": [
        -1520,
        1060
      ],
      "parameters": {
        "sessionKey": "={{ $json.body.message.chat.id }}",
        "sessionIdType": "customKey"
      },
      "typeVersion": 1.3
    },
    {
      "id": "b9b2b497-1018-40ad-b1bd-0e04cbfdb95b",
      "name": "付箋",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -2480,
        400
      ],
      "parameters": {
        "color": 2,
        "width": 560,
        "height": 640,
        "content": "## Receive Webhook from Telegram\nSetup telegram hook using the HTTP node below. Replace the api key placeholder in the URL field of the node.\nReplace the URL with the one generated from the Webhook trigger node.\n"
      },
      "typeVersion": 1
    },
    {
      "id": "6fd8fd1b-0ec2-402a-8d97-13bbc6ca6ca2",
      "name": "OpenRouterチャットモデル",
      "type": "@n8n/n8n-nodes-langchain.lmChatOpenRouter",
      "position": [
        -1660,
        1060
      ],
      "parameters": {
        "model": "anthropic/claude-3.7-sonnet",
        "options": {}
      },
      "credentials": {
        "openRouterApi": {
          "id": "mShT6DheOqjTyDCh",
          "name": "OpenRouter account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "273d9378-bbea-49ea-8a4c-cf473da4639e",
      "name": "「ワークフローテスト」クリック時",
      "type": "n8n-nodes-base.manualTrigger",
      "position": [
        -2400,
        580
      ],
      "parameters": {},
      "typeVersion": 1
    },
    {
      "id": "4f77a573-e729-4ca2-9263-005c9c67b21a",
      "name": "Telegram Webhook を設定",
      "type": "n8n-nodes-base.httpRequest",
      "position": [
        -2140,
        580
      ],
      "parameters": {
        "url": "https://api.telegram.org/bot<your-api-token>/setWebhook",
        "options": {},
        "sendBody": true,
        "bodyParameters": {
          "parameters": [
            {
              "name": "url",
              "value": "<the url generated from your workflow>"
            }
          ]
        }
      },
      "typeVersion": 4.2
    },
    {
      "id": "b29f6cbd-2ca1-455e-9372-4d7c1aee2811",
      "name": "Telegram からのメッセージトリガーを受信",
      "type": "n8n-nodes-base.webhook",
      "position": [
        -2280,
        840
      ],
      "webhookId": "4f1caff9-e22f-426b-b5da-f5175be0a7bc",
      "parameters": {
        "path": "4f1caff9-e22f-426b-b5da-f5175be0a7bc",
        "options": {},
        "httpMethod": "POST"
      },
      "typeVersion": 2
    },
    {
      "id": "f8b25f38-143b-4fc8-890c-03701bde0809",
      "name": "タイピングアクション",
      "type": "n8n-nodes-base.telegram",
      "position": [
        -1040,
        260
      ],
      "webhookId": "84423ab1-dbb7-4105-9bb3-98abdf1a42bf",
      "parameters": {
        "chatId": "={{ $('Trigger by the main workflow').item.json.chatId }}",
        "operation": "sendChatAction"
      },
      "credentials": {
        "telegramApi": {
          "id": "GY19yNGJWcslVpXr",
          "name": "Telegram account"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "22d5b740-0ad4-4e4d-b5b4-7961e131d3bd",
      "name": "タイピングアクション起動用サブワークフロー",
      "type": "n8n-nodes-base.executeWorkflow",
      "position": [
        -1580,
        260
      ],
      "parameters": {
        "mode": "each",
        "options": {
          "waitForSubWorkflow": false
        },
        "workflowId": {
          "__rl": true,
          "mode": "list",
          "value": "nnFhm4hEcyaMNkXV",
          "cachedResultName": "Basic Bright Data MCP"
        },
        "workflowInputs": {
          "value": {
            "chatId": "={{ $json.body.message.chat.id }}",
            "executionId": "={{ $execution.id }}"
          },
          "schema": [
            {
              "id": "executionId",
              "type": "string",
              "display": true,
              "required": false,
              "displayName": "executionId",
              "defaultMatch": false,
              "canBeUsedToMatch": true
            },
            {
              "id": "chatId",
              "type": "number",
              "display": true,
              "required": false,
              "displayName": "chatId",
              "defaultMatch": false,
              "canBeUsedToMatch": true
            }
          ],
          "mappingMode": "defineBelow",
          "matchingColumns": [],
          "attemptToConvertTypes": false,
          "convertFieldsToString": true
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "a2d0a7ba-df6b-43d3-9fb4-1026e3d4d154",
      "name": "付箋1",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1760,
        680
      ],
      "parameters": {
        "color": 3,
        "width": 620,
        "height": 560,
        "content": "## AI Agent with Bright Data MCP as a tool\nHost your SSE server using Supergateway or similar tools. Please check the template’s description for more instruction to setup the SSE from STDIO  command. Then paste the SSE endpoint tinthe MCP tool below."
      },
      "typeVersion": 1
    },
    {
      "id": "a4dd5168-8a4f-4ec6-8d3c-992ceb7db7ff",
      "name": "付箋2",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -820,
        700
      ],
      "parameters": {
        "color": 5,
        "width": 560,
        "height": 460,
        "content": "## Send the agent's message via Telegram Bot"
      },
      "typeVersion": 1
    },
    {
      "id": "84999800-2659-4e4d-8771-d9c5f7ff4e2a",
      "name": "付箋3",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1720,
        120
      ],
      "parameters": {
        "color": 4,
        "width": 1560,
        "height": 500,
        "content": "## Loop the typing action in Telegram\nTyping action last fro 10 seconds only, so while the agent is still processing query, execute this tool in a loop until it succeed"
      },
      "typeVersion": 1
    },
    {
      "id": "266b1d20-452b-47fc-9632-437bf7f3abac",
      "name": "エラーメッセージ返信",
      "type": "n8n-nodes-base.telegram",
      "position": [
        320,
        280
      ],
      "webhookId": "2f426e92-cd04-4f68-a7c0-276c7a025429",
      "parameters": {
        "text": "There's an error with the bot. Please try again later.",
        "chatId": "={{ $('Trigger by the main workflow').item.json.chatId }}",
        "additionalFields": {
          "appendAttribution": false
        }
      },
      "credentials": {
        "telegramApi": {
          "id": "GY19yNGJWcslVpXr",
          "name": "Telegram account"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "4be1ec2b-3ef2-45b8-b1d4-cf39791654f2",
      "name": "付箋4",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        0,
        80
      ],
      "parameters": {
        "width": 560,
        "height": 500,
        "content": "## Reply error message to the user on error"
      },
      "typeVersion": 1
    },
    {
      "id": "a3d321c8-4e9d-4c0e-86b5-da002b0ac29d",
      "name": "MCPクライアント",
      "type": "@n8n/n8n-nodes-langchain.mcpClientTool",
      "position": [
        -1340,
        1080
      ],
      "parameters": {
        "sseEndpoint": "http://localhost:8000"
      },
      "typeVersion": 1
    },
    {
      "id": "c716a991-17e0-4de4-af0d-ba6e44b5c6d2",
      "name": "N8N の実行完了を確認",
      "type": "n8n-nodes-base.n8n",
      "position": [
        -600,
        260
      ],
      "parameters": {
        "options": {},
        "resource": "execution",
        "operation": "get",
        "executionId": "={{ $('Trigger by the main workflow').item.json.executionId }}",
        "requestOptions": {}
      },
      "credentials": {
        "n8nApi": {
          "id": "oYyQ7JNyppFRzPaV",
          "name": "n8n account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "b6f08d79-16a5-47a7-800d-7c8ba902ab52",
      "name": "N8N 実行が完了した場合",
      "type": "n8n-nodes-base.if",
      "position": [
        -340,
        320
      ],
      "parameters": {
        "options": {},
        "conditions": {
          "options": {
            "version": 2,
            "leftValue": "",
            "caseSensitive": true,
            "typeValidation": "strict"
          },
          "combinator": "and",
          "conditions": [
            {
              "id": "ad6687c9-24a0-4332-8b0f-ec1aa0751cfc",
              "operator": {
                "type": "boolean",
                "operation": "false",
                "singleValue": true
              },
              "leftValue": "={{ $json.finished }}",
              "rightValue": ""
            }
          ]
        }
      },
      "typeVersion": 2.2
    },
    {
      "id": "38342c4f-b020-4dc5-b633-ebaaf2582fef",
      "name": "N8N ステータスが成功か確認",
      "type": "n8n-nodes-base.if",
      "position": [
        100,
        280
      ],
      "parameters": {
        "options": {},
        "conditions": {
          "options": {
            "version": 2,
            "leftValue": "",
            "caseSensitive": true,
            "typeValidation": "strict"
          },
          "combinator": "and",
          "conditions": [
            {
              "id": "ad6687c9-24a0-4332-8b0f-ec1aa0751cfc",
              "operator": {
                "type": "string",
                "operation": "notEquals"
              },
              "leftValue": "={{ $json.status }}",
              "rightValue": "success"
            }
          ]
        }
      },
      "typeVersion": 2.2
    },
    {
      "id": "dd3c7d3e-b011-4856-b41e-c17882a19aab",
      "name": "AI出力を Telegram 経由でユーザーに送信",
      "type": "n8n-nodes-base.telegram",
      "position": [
        -580,
        840
      ],
      "webhookId": "56e83f5d-ba64-458d-9a5b-6c3d8ae6f584",
      "parameters": {
        "text": "={{ $json.output }}",
        "chatId": "={{ $('Receive Message Trigger from Telegram').item.json.body.message.chat.id }}",
        "additionalFields": {
          "appendAttribution": false
        }
      },
      "credentials": {
        "telegramApi": {
          "id": "GY19yNGJWcslVpXr",
          "name": "Telegram account"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "d415ca44-e93b-4e10-8af6-f0f6cc059e26",
      "name": "タイピングアクション完了を10秒間待機",
      "type": "n8n-nodes-base.wait",
      "position": [
        -820,
        260
      ],
      "webhookId": "812d8e5e-2b50-4cbd-a4b5-f18640aa0e61",
      "parameters": {
        "amount": 10
      },
      "typeVersion": 1.1
    },
    {
      "id": "6d7822c9-ac66-443f-909b-83596dd738c0",
      "name": "メインワークフローによるトリガー",
      "type": "n8n-nodes-base.executeWorkflowTrigger",
      "position": [
        -1300,
        260
      ],
      "parameters": {
        "workflowInputs": {
          "values": [
            {
              "name": "executionId"
            },
            {
              "name": "chatId",
              "type": "number"
            }
          ]
        }
      },
      "typeVersion": 1.1
    }
  ],
  "pinData": {},
  "connections": {
    "9be111d1-4ea3-4c43-8b75-66a1123002fd": {
      "main": [
        [
          {
            "node": "dd3c7d3e-b011-4856-b41e-c17882a19aab",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "a3d321c8-4e9d-4c0e-86b5-da002b0ac29d": {
      "ai_tool": [
        [
          {
            "node": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
            "type": "ai_tool",
            "index": 0
          }
        ]
      ]
    },
    "860579ca-110e-4b7d-848a-e4085e05a6a6": {
      "ai_memory": [
        [
          {
            "node": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
            "type": "ai_memory",
            "index": 0
          }
        ]
      ]
    },
    "f8b25f38-143b-4fc8-890c-03701bde0809": {
      "main": [
        [
          {
            "node": "d415ca44-e93b-4e10-8af6-f0f6cc059e26",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "6fd8fd1b-0ec2-402a-8d97-13bbc6ca6ca2": {
      "ai_languageModel": [
        [
          {
            "node": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
            "type": "ai_languageModel",
            "index": 0
          }
        ]
      ]
    },
    "6d7822c9-ac66-443f-909b-83596dd738c0": {
      "main": [
        [
          {
            "node": "f8b25f38-143b-4fc8-890c-03701bde0809",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "b6f08d79-16a5-47a7-800d-7c8ba902ab52": {
      "main": [
        [
          {
            "node": "f8b25f38-143b-4fc8-890c-03701bde0809",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "38342c4f-b020-4dc5-b633-ebaaf2582fef",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "273d9378-bbea-49ea-8a4c-cf473da4639e": {
      "main": [
        [
          {
            "node": "4f77a573-e729-4ca2-9263-005c9c67b21a",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "38342c4f-b020-4dc5-b633-ebaaf2582fef": {
      "main": [
        [
          {
            "node": "266b1d20-452b-47fc-9632-437bf7f3abac",
            "type": "main",
            "index": 0
          }
        ],
        []
      ]
    },
    "b29f6cbd-2ca1-455e-9372-4d7c1aee2811": {
      "main": [
        [
          {
            "node": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
            "type": "main",
            "index": 0
          },
          {
            "node": "22d5b740-0ad4-4e4d-b5b4-7961e131d3bd",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "c716a991-17e0-4de4-af0d-ba6e44b5c6d2": {
      "main": [
        [
          {
            "node": "b6f08d79-16a5-47a7-800d-7c8ba902ab52",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "d415ca44-e93b-4e10-8af6-f0f6cc059e26": {
      "main": [
        [
          {
            "node": "c716a991-17e0-4de4-af0d-ba6e44b5c6d2",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
よくある質問

このワークフローの使い方は?

上記のJSON設定コードをコピーし、n8nインスタンスで新しいワークフローを作成して「JSONからインポート」を選択、設定を貼り付けて認証情報を必要に応じて変更してください。

このワークフローはどんな場面に適していますか?

上級 - エンジニアリング, ビルディングブロック, 人工知能

有料ですか?

このワークフローは完全無料です。ただし、ワークフローで使用するサードパーティサービス(OpenAI APIなど)は別途料金が発生する場合があります。

ワークフロー情報
難易度
上級
ノード数21
カテゴリー3
ノードタイプ14
難易度説明

上級者向け、16ノード以上の複雑なワークフロー

外部リンク
n8n.ioで表示

このワークフローを共有

カテゴリー

カテゴリー: 34