Robot de extracción de datos de Telegram con IA basado en Bright Data MCP
Avanzado
Este es unEngineering, Building Blocks, AIflujo de automatización del dominio deautomatización que contiene 21 nodos.Utiliza principalmente nodos como If, N8n, Wait, Webhook, Telegram, combinando tecnología de inteligencia artificial para lograr automatización inteligente. Robot de extracción de datos para Telegram impulsado por AI, integrando Bright Data MCP
Requisitos previos
- •Punto final de HTTP Webhook (n8n generará automáticamente)
- •Bot Token de Telegram
- •Pueden requerirse credenciales de autenticación para la API de destino
Nodos utilizados (21)
Vista previa del flujo de trabajo
Visualización de las conexiones entre nodos, con soporte para zoom y panorámica
Exportar flujo de trabajo
Copie la siguiente configuración JSON en n8n para importar y usar este flujo de trabajo
{
"meta": {
"instanceId": "4e6be3a68285934388a854ac0ffdc5e5500688d5cdb88d0ec2d734e85f097355",
"templateCredsSetupCompleted": true
},
"nodes": [
{
"id": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
"name": "Agente de IA",
"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": "Memoria Simple",
"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": "Nota Adhesiva",
"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": "Modelo de Chat 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": "Al hacer clic en 'Probar flujo de trabajo'",
"type": "n8n-nodes-base.manualTrigger",
"position": [
-2400,
580
],
"parameters": {},
"typeVersion": 1
},
{
"id": "4f77a573-e729-4ca2-9263-005c9c67b21a",
"name": "Establecer 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": "Disparador de Recepción de Mensaje desde 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": "Acción de Escribir",
"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": "Subflujo para disparar Acción de Escribir",
"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": "Nota Adhesiva1",
"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": "Nota Adhesiva2",
"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": "Nota Adhesiva3",
"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": "Responder Mensaje de Error",
"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": "Nota Adhesiva4",
"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": "Cliente MCP",
"type": "@n8n/n8n-nodes-langchain.mcpClientTool",
"position": [
-1340,
1080
],
"parameters": {
"sseEndpoint": "http://localhost:8000"
},
"typeVersion": 1
},
{
"id": "c716a991-17e0-4de4-af0d-ba6e44b5c6d2",
"name": "Verificar si la ejecución en N8N ha finalizado",
"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": "Si la ejecución en N8N ha finalizado",
"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": "Verificar si el estado de N8N es éxito",
"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": "Enviar salida de la IA al usuario vía 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": "Esperar a que finalice la acción de escribir por 10 segundos",
"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": "Disparado por el flujo de trabajo principal",
"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
}
]
]
}
}
}Preguntas frecuentes
¿Cómo usar este flujo de trabajo?
Copie el código de configuración JSON de arriba, cree un nuevo flujo de trabajo en su instancia de n8n y seleccione "Importar desde JSON", pegue la configuración y luego modifique la configuración de credenciales según sea necesario.
¿En qué escenarios es adecuado este flujo de trabajo?
Avanzado - Ingeniería, Bloques de construcción, Inteligencia Artificial
¿Es de pago?
Este flujo de trabajo es completamente gratuito, puede importarlo y usarlo directamente. Sin embargo, tenga en cuenta que los servicios de terceros utilizados en el flujo de trabajo (como la API de OpenAI) pueden requerir un pago por su cuenta.
Flujos de trabajo relacionados recomendados
Asistente de IA inteligente: conversar con archivos de almacenamiento de Supabase y Google Drive
AIinteligenteasistente：与Supabase存储yGoogle Drive文件对话
If
Set
Wait
+
If
Set
Wait
62 NodosMark Shcherbakov
Ingeniería
基于AIde潜在cliente信息增强（Bright Data MCPyGoogle Sheets）
基于AIde潜在cliente信息增强：usoBright Data MCPyGoogle Sheets
If
Set
Wait
+
If
Set
Wait
51 NodosCyril Nicko Gaspar
Ventas
Procesamiento por lotes de indicaciones usando la API de Anthropic Claude
Procesamiento por lotes de indicaciones con la API de Anthropic Claude
If
Set
Code
+
If
Set
Code
39 NodosGreg Evseev
Bloques de construcción
Explorar nodos de n8n en la biblioteca de referencias visuales
Explorar nodos de n8n en la base de referencia visual
If
Ftp
Set
+
If
Ftp
Set
113 NodosI versus AI
Otros
Radar tecnológico
usoSQLdatos库、RAGy路由agente构建AI驱动de技术雷达顾问
If
Code
Cron
+
If
Code
Cron
53 NodosSean Lon
Ingeniería
Extractor de arquitectura de API
Extractor de arquitectura de API
If
Set
Code
+
If
Set
Code
88 NodosPolina Medvedieva
Ingeniería
Información del flujo de trabajo
Nivel de dificultad
Avanzado
Número de nodos21
Categoría3
Tipos de nodos14
Descripción de la dificultad
Autor
Cyril Nicko Gaspar
@cngasparEnlaces externos
Ver en n8n.io →
Compartir este flujo de trabajo