KI-Telegramm-Datenextraktionsroboter basierend auf Bright Data MCP

Experte

Dies ist ein Engineering, Building Blocks, AI-Bereich Automatisierungsworkflow mit 21 Nodes. Hauptsächlich werden If, N8n, Wait, Webhook, Telegram und andere Nodes verwendet, kombiniert mit KI-Technologie für intelligente Automatisierung. Telegram-Datenextraktionsbot mit integriertem Bright Data MCP

Voraussetzungen
  • HTTP Webhook-Endpunkt (wird von n8n automatisch generiert)
  • Telegram Bot Token
  • Möglicherweise sind Ziel-API-Anmeldedaten erforderlich
Workflow-Vorschau
Visualisierung der Node-Verbindungen, mit Zoom und Pan
Workflow exportieren
Kopieren Sie die folgende JSON-Konfiguration und importieren Sie sie in n8n
{
  "meta": {
    "instanceId": "4e6be3a68285934388a854ac0ffdc5e5500688d5cdb88d0ec2d734e85f097355",
    "templateCredsSetupCompleted": true
  },
  "nodes": [
    {
      "id": "9be111d1-4ea3-4c43-8b75-66a1123002fd",
      "name": "KI-Agent",
      "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": "Einfacher Speicher",
      "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": "Haftnotiz",
      "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-Modell",
      "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": "Bei Klick auf 'Workflow testen'",
      "type": "n8n-nodes-base.manualTrigger",
      "position": [
        -2400,
        580
      ],
      "parameters": {},
      "typeVersion": 1
    },
    {
      "id": "4f77a573-e729-4ca2-9263-005c9c67b21a",
      "name": "Telegram Webhook setzen",
      "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": "Nachrichtentrigger von Telegram empfangen",
      "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": "Eingabeaktion",
      "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 zur Auslösung der Eingabeaktion",
      "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": "Haftnotiz1",
      "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": "Haftnotiz2",
      "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": "Haftnotiz3",
      "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": "Fehlermeldung antworten",
      "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": "Haftnotiz4",
      "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": "Prüfen, ob Ausführung in N8N abgeschlossen ist",
      "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": "Wenn N8N-Ausführung abgeschlossen ist",
      "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": "Prüfen, ob N8N-Status Erfolg ist",
      "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": "KI-Ausgabe über Telegram an Benutzer senden",
      "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": "Auf Abschluss der Eingabeaktion warten (10 Sekunden)",
      "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": "Durch Haupt-Workflow ausgelöst",
      "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
          }
        ]
      ]
    }
  }
}
Häufig gestellte Fragen

Wie verwende ich diesen Workflow?

Kopieren Sie den obigen JSON-Code, erstellen Sie einen neuen Workflow in Ihrer n8n-Instanz und wählen Sie "Aus JSON importieren". Fügen Sie die Konfiguration ein und passen Sie die Anmeldedaten nach Bedarf an.

Für welche Szenarien ist dieser Workflow geeignet?

Experte - Engineering, Bausteine, Künstliche Intelligenz

Ist es kostenpflichtig?

Dieser Workflow ist völlig kostenlos. Beachten Sie jedoch, dass Drittanbieterdienste (wie OpenAI API), die im Workflow verwendet werden, möglicherweise kostenpflichtig sind.

Workflow-Informationen
Schwierigkeitsgrad
Experte
Anzahl der Nodes21
Kategorie3
Node-Typen14
Schwierigkeitsbeschreibung

Für fortgeschrittene Benutzer, komplexe Workflows mit 16+ Nodes

Externe Links
Auf n8n.io ansehen

Diesen Workflow teilen

Kategorien

Kategorien: 34