基于 Bright Data MCP 的 AI Telegram 数据提取机器人
高级
这是一个Engineering, Building Blocks, AI领域的自动化工作流，包含 21 个节点。主要使用 If, N8n, Wait, Webhook, Telegram 等节点，结合人工智能技术实现智能自动化。 集成 Bright Data MCP 的 AI Telegram 数据提取机器人
前置要求
- •HTTP Webhook 端点（n8n 会自动生成）
- •Telegram Bot Token
- •可能需要目标 API 的认证凭证
使用的节点 (21)
工作流预览
可视化展示节点连接关系，支持缩放和平移
导出工作流
复制以下 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 Chat Model",
"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": "当点击时 ‘Test workflow’",
"type": "n8n-nodes-base.manualTrigger",
"position": [
-2400,
580
],
"parameters": {},
"typeVersion": 1
},
{
"id": "4f77a573-e729-4ca2-9263-005c9c67b21a",
"name": "Set 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": "Receive Message Trigger from 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": "Typing action",
"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": "Sub-workflow to trigger Typing Action",
"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": "Reply Error Message",
"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 Client",
"type": "@n8n/n8n-nodes-langchain.mcpClientTool",
"position": [
-1340,
1080
],
"parameters": {
"sseEndpoint": "http://localhost:8000"
},
"typeVersion": 1
},
{
"id": "c716a991-17e0-4de4-af0d-ba6e44b5c6d2",
"name": "Check if the execution in N8N is finished",
"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": "If the N8N execution is finished",
"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": "Check if the N8N status is success",
"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": "Send AI’s output to the user via 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": "等待 for the typing action to finish by 10 seconds",
"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": "Trigger by the main workflow",
"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）可能需要您自行付费。
相关工作流推荐
AI智能助手：与Supabase存储和Google Drive文件对话
AI智能助手：与Supabase存储和Google Drive文件对话
If
Set
Wait
+
If
Set
Wait
62 节点Mark Shcherbakov
工程
基于AI的潜在客户信息增强（Bright Data MCP和Google Sheets）
基于AI的潜在客户信息增强：使用Bright Data MCP和Google Sheets
If
Set
Wait
+
If
Set
Wait
51 节点Cyril Nicko Gaspar
销售
使用 Anthropic Claude API 批量处理提示
使用 Anthropic Claude API 批量处理提示
If
Set
Code
+
If
Set
Code
39 节点Greg Evseev
构建模块
在可视化参考库中探索n8n节点
在可视化参考库中探索n8n节点
If
Ftp
Set
+
If
Ftp
Set
113 节点I versus AI
其他
使用SQL数据库、RAG和路由代理构建AI驱动的技术雷达顾问
使用SQL数据库、RAG和路由代理构建AI驱动的技术雷达顾问
If
Code
Cron
+
If
Code
Cron
53 节点Sean Lon
工程
API架构提取器
API架构提取器
If
Set
Code
+
If
Set
Code
88 节点Polina Medvedieva
工程
