8
n8n Españolamn8n.com

Chat de Telegram con búfer

Avanzado

Este es unBuilding Blocks, AIflujo de automatización del dominio deautomatización que contiene 22 nodos.Utiliza principalmente nodos como If, Sort, Wait, Supabase, Telegram, combinando tecnología de inteligencia artificial para lograr automatización inteligente. Permitir a los usuarios enviar secuencias de mensajes al agente AI en Telegram

Requisitos previos
  • •URL y Clave de API de Supabase
  • •Bot Token de Telegram
  • •Clave de API de OpenAI
  • •Información de conexión de la base de datos PostgreSQL

Nodos utilizados (22)

If
NoOp
Sort
Wait
Supabase
Telegram
Aggregate
StickyNote
Agent
TelegramTrigger
LmChatOpenAi
MemoryPostgresChat

Categoría

Bloques de construcción
Inteligencia Artificial
Vista previa del flujo de trabajo
Visualización de las conexiones entre nodos, con soporte para zoom y panorámica
React Flow
Exportar flujo de trabajo
Copie la siguiente configuración JSON en n8n para importar y usar este flujo de trabajo
{
  "id": "DnHvQ3KL8v8r5L5Z",
  "meta": {
    "instanceId": "ac63467607103d9c95dd644384984672b90b1cb03e07edbaf18fe72b2a6c45bb",
    "templateCredsSetupCompleted": true
  },
  "name": "Telegram Chat with Buffering",
  "tags": [],
  "nodes": [
    {
      "id": "a3cc74e9-c696-48de-a04e-d48555641897",
      "name": "Nota adhesiva",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1640,
        -800
      ],
      "parameters": {
        "color": 7,
        "width": 220,
        "height": 280,
        "content": "## 1. Receive Message\n\n"
      },
      "typeVersion": 1
    },
    {
      "id": "ff18667d-0a31-4768-acf8-ed0d53b2f382",
      "name": "Nota adhesiva1",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        160,
        -840
      ],
      "parameters": {
        "color": 7,
        "width": 600,
        "height": 520,
        "content": "## 3. AI Assistant\n"
      },
      "typeVersion": 1
    },
    {
      "id": "ce90f954-19b6-4224-ae88-b20c4da639e6",
      "name": "Responder",
      "type": "n8n-nodes-base.telegram",
      "position": [
        920,
        -700
      ],
      "webhookId": "e3313c88-0d56-4d06-81cf-b48870dfe2fe",
      "parameters": {
        "text": "={{ $json.output }}",
        "chatId": "={{ $('Receive Message').item.json.message.chat.id }}",
        "additionalFields": {
          "appendAttribution": false
        }
      },
      "credentials": {
        "telegramApi": {
          "id": "lvrGkOs0ywXp5agp",
          "name": "Telegram bsde.ai"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "6f46d89b-034c-47ea-a217-8d007bec1531",
      "name": "Recibir mensaje",
      "type": "n8n-nodes-base.telegramTrigger",
      "position": [
        -1580,
        -680
      ],
      "webhookId": "5047a673-ca1d-4e87-b51b-893108de0a59",
      "parameters": {
        "updates": [
          "message"
        ],
        "additionalFields": {}
      },
      "credentials": {
        "telegramApi": {
          "id": "lvrGkOs0ywXp5agp",
          "name": "Telegram bsde.ai"
        }
      },
      "typeVersion": 1.1
    },
    {
      "id": "0f391daa-0e74-4058-8923-52f3c050c9ad",
      "name": "Esperar 10 segundos",
      "type": "n8n-nodes-base.wait",
      "position": [
        -1000,
        -580
      ],
      "webhookId": "87994c9a-fd20-48b6-8dbe-9af36dc40b2f",
      "parameters": {
        "amount": 10
      },
      "typeVersion": 1.1
    },
    {
      "id": "8e6495d8-db6e-4692-ade5-45239049de34",
      "name": "Nota adhesiva3",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1320,
        -760
      ],
      "parameters": {
        "color": 7,
        "width": 1400,
        "height": 440,
        "content": "## 2. Buffer Incoming Messages"
      },
      "typeVersion": 1
    },
    {
      "id": "d4876fd2-2e0b-4f82-9dc3-553f926310bd",
      "name": "Agregar a mensajes en cola",
      "type": "n8n-nodes-base.supabase",
      "position": [
        -1240,
        -680
      ],
      "parameters": {
        "tableId": "message_queue",
        "fieldsUi": {
          "fieldValues": [
            {
              "fieldId": "user_id",
              "fieldValue": "={{ $json.message.chat.id }}"
            },
            {
              "fieldId": "message",
              "fieldValue": "={{ $json.message.text }}"
            },
            {
              "fieldId": "message_id",
              "fieldValue": "={{ $json.message.message_id }}"
            }
          ]
        }
      },
      "credentials": {
        "supabaseApi": {
          "id": "1iEg1EzFrF29iqp2",
          "name": "Supabase (bsde.ai)"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "a2eeb77f-2d74-44ac-9812-c3659d2e2803",
      "name": "Sin operación, no hacer nada",
      "type": "n8n-nodes-base.noOp",
      "position": [
        -340,
        -460
      ],
      "parameters": {},
      "typeVersion": 1
    },
    {
      "id": "638fc82e-aba1-4deb-b506-33dcf4746896",
      "name": "Agregar",
      "type": "n8n-nodes-base.aggregate",
      "position": [
        220,
        -700
      ],
      "parameters": {
        "options": {},
        "fieldsToAggregate": {
          "fieldToAggregate": [
            {
              "fieldToAggregate": "message"
            }
          ]
        }
      },
      "typeVersion": 1
    },
    {
      "id": "772f60e5-e52f-4779-aa03-e4d532ee4b5c",
      "name": "Eliminar mensajes en cola",
      "type": "n8n-nodes-base.supabase",
      "position": [
        -100,
        -700
      ],
      "parameters": {
        "filters": {
          "conditions": [
            {
              "keyName": "user_id",
              "keyValue": "={{ $json.user_id }}",
              "condition": "eq"
            }
          ]
        },
        "tableId": "message_queue",
        "operation": "delete"
      },
      "credentials": {
        "supabaseApi": {
          "id": "1iEg1EzFrF29iqp2",
          "name": "Supabase (bsde.ai)"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "16b46a70-85a0-4c8c-94ba-172ebe9aafa4",
      "name": "Nota adhesiva2",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        860,
        -780
      ],
      "parameters": {
        "color": 7,
        "width": 280,
        "height": 260,
        "content": "## 4. Send Reply\n\n\n"
      },
      "typeVersion": 1
    },
    {
      "id": "9162f110-465f-4cd6-9f03-17751d7e43a4",
      "name": "OpenAI Chat Model",
      "type": "@n8n/n8n-nodes-langchain.lmChatOpenAi",
      "position": [
        380,
        -460
      ],
      "parameters": {
        "model": {
          "__rl": true,
          "mode": "list",
          "value": "gpt-4o-mini"
        },
        "options": {}
      },
      "credentials": {
        "openAiApi": {
          "id": "1OMpAMAKR9l3eUDI",
          "name": "OpenAi account"
        }
      },
      "typeVersion": 1.2
    },
    {
      "id": "b47ef0c9-725b-4837-b9e9-96a4ff2b3636",
      "name": "Ordenar por ID de mensaje",
      "type": "n8n-nodes-base.sort",
      "position": [
        -580,
        -680
      ],
      "parameters": {
        "options": {},
        "sortFieldsUi": {
          "sortField": [
            {
              "fieldName": "message_id"
            }
          ]
        }
      },
      "typeVersion": 1
    },
    {
      "id": "1aa80c99-eec8-4174-bcf3-c6873354ed0f",
      "name": "Obtener mensajes en cola",
      "type": "n8n-nodes-base.supabase",
      "position": [
        -780,
        -680
      ],
      "parameters": {
        "filters": {
          "conditions": [
            {
              "keyName": "user_id",
              "keyValue": "={{ $('Receive Message').item.json.message.from.id }}",
              "condition": "eq"
            }
          ]
        },
        "tableId": "message_queue",
        "operation": "getAll",
        "returnAll": true
      },
      "credentials": {
        "supabaseApi": {
          "id": "1iEg1EzFrF29iqp2",
          "name": "Supabase (bsde.ai)"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "85050328-b5aa-47fe-802c-7d9f31f225cb",
      "name": "Verificar mensaje más reciente",
      "type": "n8n-nodes-base.if",
      "position": [
        -360,
        -680
      ],
      "parameters": {
        "options": {},
        "conditions": {
          "options": {
            "version": 2,
            "leftValue": "",
            "caseSensitive": true,
            "typeValidation": "loose"
          },
          "combinator": "and",
          "conditions": [
            {
              "id": "8852bab7-230e-442a-a4a2-994e979c8f9f",
              "operator": {
                "type": "number",
                "operation": "equals"
              },
              "leftValue": "={{ $input.last().json.message_id }}\n",
              "rightValue": "={{ $('Receive Message').item.json.message.message_id }}"
            }
          ]
        },
        "looseTypeValidation": true
      },
      "typeVersion": 2.2
    },
    {
      "id": "bed86d81-bb57-42ce-aaa7-4bdc21e1651c",
      "name": "Agente de IA",
      "type": "@n8n/n8n-nodes-langchain.agent",
      "position": [
        420,
        -700
      ],
      "parameters": {
        "text": "={{ $json.message.join(String.fromCharCode(10)) }}",
        "options": {},
        "promptType": "define"
      },
      "typeVersion": 1.7
    },
    {
      "id": "4f468a14-fbea-44ec-a2b8-e4b3785c0362",
      "name": "Memoria de chat Postgres",
      "type": "@n8n/n8n-nodes-langchain.memoryPostgresChat",
      "position": [
        560,
        -460
      ],
      "parameters": {
        "sessionKey": "={{ $('Receive Message').item.json.message.chat.id }}",
        "sessionIdType": "customKey"
      },
      "credentials": {
        "postgres": {
          "id": "tzLXHvhykxvYghPC",
          "name": "bsde.ai Supabase (Session Pooler)"
        }
      },
      "typeVersion": 1.3
    },
    {
      "id": "610516e8-d4ad-448e-ac97-17aad1a31862",
      "name": "Nota adhesiva4",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -2420,
        -820
      ],
      "parameters": {
        "width": 700,
        "height": 420,
        "content": "## Allow Users to Send a Sequence of Messages to an AI Agent in Telegram with Supabase\n### Use Case\nWhen creating chatbots that interface through applications such as **Telegram** and **WhatsApp**, users can often sends multiple shorter messages in quick succession, in place of a single, longer message. This workflow accounts for this behaviour.\n### What it Does\nThis workflow allows users to send several messages in quick succession, treating them as one coherent conversation instead of separate messages requiring individual responses. \n### How it Works\n1. When messages arrive, they are stored in a **Supabase PostgreSQL** table\n2. The system waits briefly to see if additional messages arrive\n3. If no new messages arrive within the waiting period, all queued messages are:\n   - Combined and processed as a single conversation\n   - Responded to with one unified reply\n   - Deleted from the queue"
      },
      "typeVersion": 1
    },
    {
      "id": "c8bd8777-fb0f-4941-8674-f5bb7c264506",
      "name": "Nota adhesiva5",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1640,
        -1060
      ],
      "parameters": {
        "width": 520,
        "height": 220,
        "content": "### Setup\n1. Create a table in Supabase called **message_queue**. It needs to have the following columns: **user_id** (`uint8`), **message** (`text`), and **message_id** (`uint8`)\n2. Add your **Telegram**, **Supabase**, **OpenAI**, and **PostgreSQL** credentials\n3. Activate the workflow and test by sending multiple messages the Telegram bot in one go\n4. Wait ten seconds after which you will receive a single reply to all of your messages"
      },
      "typeVersion": 1
    },
    {
      "id": "24604fc7-7957-4e20-8303-b31f2ce1e257",
      "name": "Nota adhesiva6",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        -1060,
        -700
      ],
      "parameters": {
        "color": 5,
        "width": 220,
        "height": 280,
        "content": "### Modification\nChange the value of *Wait Amount* to vary the buffering window"
      },
      "typeVersion": 1
    },
    {
      "id": "24f388f3-5655-4bd4-9c30-978efb2dc400",
      "name": "Nota adhesiva8",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        180,
        -480
      ],
      "parameters": {
        "color": 5,
        "width": 340,
        "height": 140,
        "content": "### Modification\nReplace this sub-node \nto use a different language\n model"
      },
      "typeVersion": 1
    },
    {
      "id": "3db12526-6b97-4e3a-b53d-987f5d20c46e",
      "name": "Nota adhesiva9",
      "type": "n8n-nodes-base.stickyNote",
      "position": [
        380,
        -800
      ],
      "parameters": {
        "color": 5,
        "width": 340,
        "height": 240,
        "content": "### Modification\nAdd a **System Message** to tailor the chatbot to your use case"
      },
      "typeVersion": 1
    }
  ],
  "active": true,
  "pinData": {},
  "settings": {
    "callerPolicy": "workflowsFromSameOwner",
    "executionOrder": "v1"
  },
  "versionId": "e415eb18-1bb9-426b-b759-0ba269db1f8f",
  "connections": {
    "bed86d81-bb57-42ce-aaa7-4bdc21e1651c": {
      "main": [
        [
          {
            "node": "ce90f954-19b6-4224-ae88-b20c4da639e6",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "638fc82e-aba1-4deb-b506-33dcf4746896": {
      "main": [
        [
          {
            "node": "bed86d81-bb57-42ce-aaa7-4bdc21e1651c",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "6f46d89b-034c-47ea-a217-8d007bec1531": {
      "main": [
        [
          {
            "node": "d4876fd2-2e0b-4f82-9dc3-553f926310bd",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "0f391daa-0e74-4058-8923-52f3c050c9ad": {
      "main": [
        [
          {
            "node": "1aa80c99-eec8-4174-bcf3-c6873354ed0f",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "9162f110-465f-4cd6-9f03-17751d7e43a4": {
      "ai_languageModel": [
        [
          {
            "node": "bed86d81-bb57-42ce-aaa7-4bdc21e1651c",
            "type": "ai_languageModel",
            "index": 0
          }
        ]
      ]
    },
    "b47ef0c9-725b-4837-b9e9-96a4ff2b3636": {
      "main": [
        [
          {
            "node": "85050328-b5aa-47fe-802c-7d9f31f225cb",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "1aa80c99-eec8-4174-bcf3-c6873354ed0f": {
      "main": [
        [
          {
            "node": "b47ef0c9-725b-4837-b9e9-96a4ff2b3636",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "4f468a14-fbea-44ec-a2b8-e4b3785c0362": {
      "ai_memory": [
        [
          {
            "node": "bed86d81-bb57-42ce-aaa7-4bdc21e1651c",
            "type": "ai_memory",
            "index": 0
          }
        ]
      ]
    },
    "d4876fd2-2e0b-4f82-9dc3-553f926310bd": {
      "main": [
        [
          {
            "node": "0f391daa-0e74-4058-8923-52f3c050c9ad",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "772f60e5-e52f-4779-aa03-e4d532ee4b5c": {
      "main": [
        [
          {
            "node": "638fc82e-aba1-4deb-b506-33dcf4746896",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "85050328-b5aa-47fe-802c-7d9f31f225cb": {
      "main": [
        [
          {
            "node": "772f60e5-e52f-4779-aa03-e4d532ee4b5c",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "a2eeb77f-2d74-44ac-9812-c3659d2e2803",
            "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 - 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

[Plantilla] Tienda de mascotas AI v8
🐶 Asistente de tienda de mascotas AI - Integrado con GPT-4o, Google Calendar y WhatsApp/Instagram/Facebook
If
N8n
Set
+
If
N8n
Set
244 NodosAmanda Benks
Ventas
AIcorreo electrónico分诊与GPT-4警报系统及Telegramnotificación
AIcorreo electrónico分诊与GPT-4警报系统及Telegramnotificación
If
Set
Gmail
+
If
Set
Gmail
104 NodosPeter Joslyn
Soporte
基于 GPT、LangChain yinteligente路由de AI 驱动cliente服务automatización
AI驱动cliente服务automatización，基于GPT、LangChainyinteligente路由
Set
Gmail
Merge
+
Set
Gmail
Merge
46 NodosPaul
Soporte
Tienda de mascotas 4
🐶 Agente AI para citas en tiendas de mascotas
If
Set
Code
+
If
Set
Code
187 NodosBruno Dias
Inteligencia Artificial
agente de restaurante AI [plantilla]
🤖 asistente de restaurante AI para WhatsApp, Instagram y Messenger
If
N8n
Set
+
If
N8n
Set
239 NodosAmanda Benks
Otros
Flujo de trabajo de correos fríos impulsado por GPT-4, con 3 correos de seguimiento completamente personalizados
Automatizar secuencias de frío personalizadas con GPT-4, Mailgun y Supabase
If
Set
Code
+
If
Set
Code
100 NodosPaul
Nutrición de leads
Información del flujo de trabajo
Nivel de dificultad
Avanzado
Número de nodos22
Categoría2
Tipos de nodos12
Descripción de la dificultad

Adecuado para usuarios avanzados, flujos de trabajo complejos con 16+ nodos

Autor
Chris Carr

Chris Carr

@chriscarr

Founder of bsde.ai, a workflow and AI agency based in the UK.

Enlaces externos
Ver en n8n.io →

Compartir este flujo de trabajo

Categorías

IA Multimodal
1540
Inteligencia Artificial
1108
Creación de contenido
695
Resumen de IA
516
Marketing
419
Chatbot de IA
251
Ingeniería
241
Investigación de mercado
203
Varios
193
Otros
176
Ventas
162
Operaciones de TI
156
Extracción de documentos
147
RAG de IA
146
Bloques de construcción
144
Redes sociales
137
Generación de leads
125
Productividad personal
117
DevOps
111
Recursos Humanos
101
Soporte
97
Nutrición de leads
87
CRM
82
Finanzas
81
Producto
77
Chatbot de soporte
76
Diseño
70
Gestión de tickets
67
Operaciones de seguridad
57
Procesamiento de facturas
53
Comercio de criptomonedas
49
Gestión de archivos
39
Gestión de proyectos
35
Wiki interno
32

Categorías: 34