Workflow qui collecte les messages utilisateurs dans Redis et les regroupe pour générer une réponse consolidée via GPT-4, optimisant ainsi la gestion de grandes quantités de messages et évitant les doublons.
Workflow qui collecte les messages utilisateurs dans Redis et les regroupe pour générer une réponse consolidée via GPT-4, optimisant ainsi la gestion de grandes quantités de messages et évitant les doublons.
{
"meta": {
"instanceId": "d1b9b74c805fea7fca1b903ee192d1d4090b516d3c254da86beb2f13b7c2ed2e",
"templateCredsSetupCompleted": true
},
"nodes": [
{
"id": "be902a85-fc31-442c-b308-a2350ec5aabb",
"name": "When clicking u2018Test workflowu2019",
"type": "n8n-nodes-base.manualTrigger",
"position": [
-760,
440
],
"parameters": {},
"typeVersion": 1
},
{
"id": "d229b686-9de4-4633-9dba-3e1fe71eedf1",
"name": "No Operation, do nothing1",
"type": "n8n-nodes-base.noOp",
"position": [
1820,
800
],
"parameters": {},
"typeVersion": 1
},
{
"id": "f583bc97-8da8-488e-ab04-5167dc7a7701",
"name": "Information Extractor",
"type": "@n8n/n8n-nodes-langchain.informationExtractor",
"position": [
2420,
540
],
"parameters": {
"text": "={{ $json.buffer.reverse().toJsonString() }}",
"options": {
"systemPromptTemplate": "Eres un experto extrayendo informaciu00f3n, tu objetivo es recolectar todos los mensajes. Procura no dejar duplicados. como resultado debes retornar un solo pu00e1rrafo con todo los mensajes."
},
"schemaType": "fromJson",
"jsonSchemaExample": "{nt"message": "all consolidated messages"n}"
},
"typeVersion": 1
},
{
"id": "5b719416-4886-4d38-9d00-30b6237db168",
"name": "OpenAI Chat Model",
"type": "@n8n/n8n-nodes-langchain.lmChatOpenAi",
"position": [
2440,
760
],
"parameters": {
"model": {
"__rl": true,
"mode": "list",
"value": "gpt-4.1-nano",
"cachedResultName": "gpt-4.1-nano"
},
"options": {}
},
"credentials": {
"openAiApi": {
"id": "IogsrRzOBSmZJS5C",
"name": "OpenAi account"
}
},
"typeVersion": 1.2
},
{
"id": "3d149fc0-caa7-4361-9bf9-33b6252b39eb",
"name": "get wait seconds",
"type": "n8n-nodes-base.code",
"position": [
-260,
500
],
"parameters": {
"jsCode": "// Function: Compute waitSecondsnconst wordCount = $json.message.split(' ').filter(w=>w).length;nreturn [{ json: { n context_id: $json.context_id,n message: $json.message,n waitSeconds: wordCount = 1}}",
"rightValue": ""
},
{
"id": "1626238d-fb00-4ce8-89df-a40a4f29f52a",
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
},
"leftValue": "={{$('Get last_seen').item.json.last_seen != null}}",
"rightValue": ""
},
{
"id": "df819099-1f6e-4bee-a017-32b729c836a3",
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
},
"leftValue": "={{($now.toMillis() - $('Get last_seen').item.json.last_seen) >= $('Mod input').item.json.waitSeconds * 1000}}",
"rightValue": ""
}
]
},
"looseTypeValidation": true
},
"typeVersion": 2.2
},
{
"id": "0c3bd62b-8cf6-4b34-8010-ebe819db9667",
"name": "Delete waiting_reply1",
"type": "n8n-nodes-base.redis",
"position": [
2940,
1000
],
"parameters": {
"key": "=buffer_count:{{$json.context_id}}",
"operation": "delete"
},
"credentials": {
"redis": {
"id": "zJtRI38KhsyVjUvP",
"name": "Redis account"
}
},
"typeVersion": 1
},
{
"id": "bbf45966-833b-4f5f-ae11-0578614eb156",
"name": "No Operation, do nothing2",
"type": "n8n-nodes-base.noOp",
"position": [
720,
540
],
"parameters": {},
"typeVersion": 1
},
{
"id": "5683eebf-ba51-4a6b-a803-de6acf1b1ea8",
"name": "Wait",
"type": "n8n-nodes-base.wait",
"position": [
2080,
880
],
"webhookId": "b8e2e214-f82b-49c2-96e2-91e093137857",
"parameters": {
"amount": "={{ Math.max(0, Math.ceil(( $('Mod input').item.json.waitSeconds * 1000 - ($now.toMillis() - $('Get last_seen').item.json.last_seen)) / 1000)) }}"
},
"typeVersion": 1.1
},
{
"id": "c0478f60-944e-4c85-bb9c-9abe0d4238c0",
"name": "When Executed by Another Workflow",
"type": "n8n-nodes-base.executeWorkflowTrigger",
"position": [
-480,
720
],
"parameters": {
"workflowInputs": {
"values": [
{
"name": "context_id"
},
{
"name": "message"
}
]
}
},
"typeVersion": 1.1
},
{
"id": "91a650b7-ddd4-4dbf-a300-523f72f0bdb5",
"name": "Mock input data",
"type": "n8n-nodes-base.set",
"position": [
-500,
500
],
"parameters": {
"options": {},
"assignments": {
"assignments": [
{
"id": "0543fdb7-4a22-4530-bdb7-ae7064732fae",
"name": "context_id",
"type": "string",
"value": "={{ $json.sessionId1 || '1lap075ha12' }}"
},
{
"id": "bead5646-a689-4deb-8f4b-b22aa97b51ca",
"name": "message",
"type": "string",
"value": "={{ $json.chatInput || 'Chat 2'}}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "cb450e32-7e19-469c-9a5c-3d9da5bf1dfa",
"name": "No Operation, do nothing3",
"type": "n8n-nodes-base.noOp",
"position": [
3320,
840
],
"parameters": {},
"typeVersion": 1
},
{
"id": "b463e405-3355-48a2-a043-42941d7025c3",
"name": "Sticky Note",
"type": "n8n-nodes-base.stickyNote",
"position": [
2880,
660
],
"parameters": {
"color": 7,
"width": 700,
"height": 780,
"content": "nnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnnn### ud83euddf9 Buffer CleanupnnAfter consolidation and reply:nn* **DELETE** keys:nn * `buffer_in:{{context_id}}`n * `buffer_count:{{context_id}}`n * `waiting_reply:{{context_id}}`n"
},
"typeVersion": 1
},
{
"id": "1b5397f8-aa7e-4b2b-afb9-5da97d99e049",
"name": "Sticky Note1",
"type": "n8n-nodes-base.stickyNote",
"position": [
-80,
60
],
"parameters": {
"color": 7,
"width": 920,
"height": 940,
"content": "### ud83dudce5 Input Buffernn1. **Save incoming message**nn * Push the new message into Redis list `buffer_in:{{context_id}}`.n2. **Update metadata**nn * Set `last_seen:{{context_id}}` to the current timestamp (with a TTL of `waitSeconds + 60`).n * INCR the counter key `buffer_count:{{context_id}}` (also expiring after `waitSeconds + 60`).n3. **Check u201cwaitingu201d flag**nn * GET `waiting_reply:{{context_id}}`.n * If itu2019s null (no batch in flight), SET it to `true` with TTL `waitSeconds` to block concurrent triggers."
},
"typeVersion": 1
},
{
"id": "edc07500-ccad-4e72-adc1-1a63a3a06609",
"name": "Sticky Note2",
"type": "n8n-nodes-base.stickyNote",
"position": [
1180,
340
],
"parameters": {
"color": 7,
"width": 1200,
"height": 820,
"content": "### u23f3 Inactivity & Threshold Checknn1. **Fetch state**nn * GET `last_seen:{{context_id}}` (when the last message arrived)n * GET `buffer_count:{{context_id}}` (how many messages are queued)n2. **Evaluate trigger**nn * **Inactivity:** `(now u2013 last_seen) u2265 waitSeconds * 1000`n * **Or threshold:** `buffer_count u2265 1` (or your desired batch size)n3. **Branch**nn * **True:** proceed to u201cGet bufferu201d and consolidate.n * **False:** exit (noOp) and let the waitingu2010node/flag mechanism retry later."
},
"typeVersion": 1
}
],
"pinData": {
"When Executed by Another Workflow": [
{
"message": "Mensaje del usuario despues de pasar por el workflow de n8n:nTexto: u00a1Hola! Quiero mu00e1s informaciu00f3n.;nImagen: ;nAudio: ;",
"context_id": "573058148988@s.whatsapp.net"
}
]
},
"connections": {
"Wait": {
"main": [
[
{
"node": "Check Inactivity + Count",
"type": "main",
"index": 0
}
]
]
},
"Map ouput": {
"main": [
[]
]
},
"Mod input": {
"main": [
[
{
"node": "waiting_reply?",
"type": "main",
"index": 0
}
]
]
},
"Get buffer": {
"main": [
[
{
"node": "Information Extractor",
"type": "main",
"index": 0
}
]
]
},
"WaitSeconds": {
"main": [
[
{
"node": "Get last_seen",
"type": "main",
"index": 0
}
]
]
},
"Get last_seen": {
"main": [
[
{
"node": "Get buffer_count",
"type": "main",
"index": 0
}
]
]
},
"Set last_seen": {
"main": [
[
{
"node": "No Operation, do nothing2",
"type": "main",
"index": 0
}
]
]
},
"waiting_reply?": {
"main": [
[
{
"node": "No Operation, do nothing2",
"type": "main",
"index": 0
}
],
[
{
"node": "Set waiting_reply",
"type": "main",
"index": 0
}
]
]
},
"Buffer messages": {
"main": [
[
{
"node": "Set buffer_count increment",
"type": "main",
"index": 0
},
{
"node": "Set last_seen",
"type": "main",
"index": 0
},
{
"node": "Get waiting_reply",
"type": "main",
"index": 0
}
]
]
},
"Mock input data": {
"main": [
[
{
"node": "get wait seconds",
"type": "main",
"index": 0
}
]
]
},
"Delete buffer_in": {
"main": [
[
{
"node": "No Operation, do nothing3",
"type": "main",
"index": 0
}
]
]
},
"Get buffer_count": {
"main": [
[
{
"node": "Check Inactivity + Count",
"type": "main",
"index": 0
}
]
]
},
"get wait seconds": {
"main": [
[
{
"node": "Buffer messages",
"type": "main",
"index": 0
}
]
]
},
"Get waiting_reply": {
"main": [
[
{
"node": "Mod input",
"type": "main",
"index": 0
}
]
]
},
"OpenAI Chat Model": {
"ai_languageModel": [
[
{
"node": "Information Extractor",
"type": "ai_languageModel",
"index": 0
}
]
]
},
"Set waiting_reply": {
"main": [
[
{
"node": "WaitSeconds",
"type": "main",
"index": 0
}
]
]
},
"Delete waiting_reply": {
"main": [
[
{
"node": "No Operation, do nothing3",
"type": "main",
"index": 0
}
]
]
},
"Delete waiting_reply1": {
"main": [
[
{
"node": "No Operation, do nothing3",
"type": "main",
"index": 0
}
]
]
},
"Information Extractor": {
"main": [
[
{
"node": "Map ouput",
"type": "main",
"index": 0
},
{
"node": "Delete buffer_in",
"type": "main",
"index": 0
},
{
"node": "Delete waiting_reply",
"type": "main",
"index": 0
},
{
"node": "Delete waiting_reply1",
"type": "main",
"index": 0
}
]
]
},
"Check Inactivity + Count": {
"main": [
[
{
"node": "Get buffer",
"type": "main",
"index": 0
}
],
[
{
"node": "No Operation, do nothing1",
"type": "main",
"index": 0
}
]
]
},
"No Operation, do nothing1": {
"main": [
[
{
"node": "Wait",
"type": "main",
"index": 0
}
]
]
},
"Set buffer_count increment": {
"main": [
[
{
"node": "No Operation, do nothing2",
"type": "main",
"index": 0
}
]
]
},
"When chat message received": {
"main": [
[
{
"node": "Mock input data",
"type": "main",
"index": 0
}
]
]
},
"When Executed by Another Workflow": {
"main": [
[
{
"node": "get wait seconds",
"type": "main",
"index": 0
}
]
]
},
"When clicking u2018Test workflowu2019": {
"main": [
[
{
"node": "Mock input data",
"type": "main",
"index": 0
}
]
]
}
}
}