Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

mqtt node #13499

Open
aeoniv opened this issue Feb 25, 2025 · 2 comments
Open

mqtt node #13499

aeoniv opened this issue Feb 25, 2025 · 2 comments
Labels
in linear Issue or PR has been created in Linear for internal review Needs Feedback Waiting for further input or clarification.

Comments

@aeoniv
Copy link

aeoniv commented Feb 25, 2025

Describe the problem/error/question

Authentication with HiveMQ mqtt broker does not work

What is the error message (if any)?

No error message, just keep loading

Please share your workflow/screenshots/recording

{
  "nodes": [
    {
      "parameters": {
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.textSplitterRecursiveCharacterTextSplitter",
      "typeVersion": 1,
      "position": [
        3540,
        4000
      ],
      "id": "b260f6aa-a5a5-4bf4-a72e-7187c4d4f172",
      "name": "Recursive Character Text Splitter"
    },
    {
      "parameters": {
        "dataType": "binary",
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.documentDefaultDataLoader",
      "typeVersion": 1,
      "position": [
        3500,
        3800
      ],
      "id": "a27cde41-1686-44e1-8c29-680c8cfe64aa",
      "name": "Default Data Loader"
    },
    {
      "parameters": {
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.embeddingsOpenAi",
      "typeVersion": 1.2,
      "position": [
        3340,
        3920
      ],
      "id": "d36478ff-1871-420a-961a-6e2b4d030594",
      "name": "Embeddings OpenAI",
      "credentials": {
        "openAiApi": {
          "id": "EPIk7ws0P1kfNA1n",
          "name": "OpenAi account"
        }
      }
    },
    {
      "parameters": {
        "mode": "insert",
        "pineconeIndex": {
          "__rl": true,
          "value": "ix88",
          "mode": "list",
          "cachedResultName": "ix88"
        },
        "options": {
          "pineconeNamespace": "ix_namespace"
        }
      },
      "type": "@n8n/n8n-nodes-langchain.vectorStorePinecone",
      "typeVersion": 1,
      "position": [
        3360,
        3460
      ],
      "id": "8c8fcb41-be25-4bb0-bb41-401269dbfeef",
      "name": "Pinecone Vector Store",
      "credentials": {
        "pineconeApi": {
          "id": "3tINVGvUOzJnYFHX",
          "name": "PineconeApi account"
        }
      }
    },
    {
      "parameters": {
        "options": {}
      },
      "type": "n8n-nodes-base.splitInBatches",
      "typeVersion": 3,
      "position": [
        3060,
        3440
      ],
      "id": "3241cdf1-17d8-480f-9a98-7d98585e22ff",
      "name": "Loop Over Items"
    },
    {
      "parameters": {
        "operation": "download",
        "fileId": {
          "__rl": true,
          "value": "={{ $json.id }}",
          "mode": "id"
        },
        "options": {}
      },
      "type": "n8n-nodes-base.googleDrive",
      "typeVersion": 3,
      "position": [
        2580,
        3440
      ],
      "id": "f8994c89-4048-479e-a09e-2a5f96fbb7db",
      "name": "Google Drive1",
      "credentials": {
        "googleDriveOAuth2Api": {
          "id": "jn9hkIGtMbQuzkrB",
          "name": "Google Drive account 5"
        }
      }
    },
    {
      "parameters": {
        "resource": "fileFolder",
        "filter": {
          "folderId": {
            "__rl": true,
            "value": "1OyshEXjMzugp6uZsCAy6HwhlZcbfIjQC",
            "mode": "list",
            "cachedResultName": "Profiles json",
            "cachedResultUrl": "https://drive.google.com/drive/folders/1OyshEXjMzugp6uZsCAy6HwhlZcbfIjQC"
          }
        },
        "options": {}
      },
      "type": "n8n-nodes-base.googleDrive",
      "typeVersion": 3,
      "position": [
        2340,
        3440
      ],
      "id": "8c5030f2-800f-462b-9285-8efc7067917f",
      "name": "Google Drive",
      "credentials": {
        "googleDriveOAuth2Api": {
          "id": "jn9hkIGtMbQuzkrB",
          "name": "Google Drive account 5"
        }
      }
    },
    {
      "parameters": {
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.embeddingsOpenAi",
      "typeVersion": 1.2,
      "position": [
        2980,
        3120
      ],
      "id": "052f29d4-fd97-4bbe-b305-298fde28d44c",
      "name": "Embeddings OpenAI2",
      "credentials": {
        "openAiApi": {
          "id": "EPIk7ws0P1kfNA1n",
          "name": "OpenAi account"
        }
      }
    },
    {
      "parameters": {
        "model": {
          "__rl": true,
          "value": "gpt-4o",
          "mode": "list",
          "cachedResultName": "gpt-4o"
        },
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.lmChatOpenAi",
      "typeVersion": 1.2,
      "position": [
        3400,
        2980
      ],
      "id": "7fe0a1b0-f669-4ddf-9b9e-f461a4e491aa",
      "name": "OpenAI Chat Model1",
      "credentials": {
        "openAiApi": {
          "id": "EPIk7ws0P1kfNA1n",
          "name": "OpenAi account"
        }
      }
    },
    {
      "parameters": {
        "pineconeIndex": {
          "__rl": true,
          "value": "ix88",
          "mode": "list",
          "cachedResultName": "ix88"
        },
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.vectorStorePinecone",
      "typeVersion": 1,
      "position": [
        2980,
        2940
      ],
      "id": "45affa12-68c2-43ed-ad56-08d99dc86ef1",
      "name": "Pinecone Vector Store1",
      "credentials": {
        "pineconeApi": {
          "id": "3tINVGvUOzJnYFHX",
          "name": "PineconeApi account"
        }
      }
    },
    {
      "parameters": {
        "name": "ix64",
        "description": "Retrieve information "
      },
      "type": "@n8n/n8n-nodes-langchain.toolVectorStore",
      "typeVersion": 1,
      "position": [
        3200,
        2800
      ],
      "id": "cbb8c216-0ebf-495c-a8d3-67cffeec7525",
      "name": "Answer questions with a vector store"
    },
    {
      "parameters": {
        "sessionIdType": "customKey",
        "sessionKey": "={{ $('When chat message received').item.json.chatInput }}"
      },
      "type": "@n8n/n8n-nodes-langchain.memoryBufferWindow",
      "typeVersion": 1.3,
      "position": [
        3100,
        2660
      ],
      "id": "a6bb8e70-45e3-49f4-9a29-0c8094fb4f2b",
      "name": "Window Buffer Memory"
    },
    {
      "parameters": {
        "model": {
          "__rl": true,
          "value": "gpt-4o",
          "mode": "list",
          "cachedResultName": "gpt-4o"
        },
        "options": {}
      },
      "type": "@n8n/n8n-nodes-langchain.lmChatOpenAi",
      "typeVersion": 1.2,
      "position": [
        2940,
        2660
      ],
      "id": "89e62e18-ae01-436f-92ff-8f017ea6f719",
      "name": "OpenAI Chat Model",
      "credentials": {
        "openAiApi": {
          "id": "EPIk7ws0P1kfNA1n",
          "name": "OpenAi account"
        }
      }
    },
    {
      "parameters": {
        "promptType": "define",
        "text": "={{ $json.chatInput }}",
        "options": {
          "systemMessage": "You are a Human Design matchmaking agent. Your job is to find compatible profiles for the input profile using the \"ix64\" vector store, which contains a database of Human Design profiles. Follow these steps:\n\n1. **Retrieve Profiles**: Use the \"ix64\" vector store to fetch all stored profiles.\n2. **Compare Input**: Analyze the input profile (available in $json.body) against each retrieved profile using these compatibility rules:\n   - **Type**: High (10 points) for Generator/Manifesting Generator + Projector, Manifestor + Generator, Reflector + Reflector; moderate (5) for similar types; low (0) for mismatches.\n   - **Authority**: High (10) for matching authorities, moderate (5) for complementary (e.g., Emotional + Sacral), low (0) for conflicts.\n   - **Profile**: High (10) for complementary profiles (e.g., 1/3 + 4/6), moderate (5) for similar profiles.\n   - **Channels**: High (10) for Companionship (shared channels) or Electromagnetic (complementary gates forming a channel, e.g., 27 + 50 = 27-50), moderate (5) for Compromise, low (0) for Dominance or no connection.\n   - **Centers**: High (10) for defined in one + undefined in other, moderate (5) for both defined/undefined.\n   - **Gates**: High (10) for matching gates (e.g., Sun_Birth), moderate (5) for complementary gates.\n3. **Score Matches**: Calculate a total score (max 60) for each retrieved profile.\n4. **Return Results**: Provide the top 3 matches (or all above 40 points) in this JSON format:\n{\n  \"user_id\": \"<input_user_id from $json.body>\",\n  \"matches\": [\n    {\n      \"user_id\": \"<matched_user_id>\",\n      \"profile\": \"<matched_profile_summary, e.g., Type and Profile>\",\n      \"score\": <score>,\n      \"reason\": \"<explanation based on key factors>\"\n    }\n  ]\n}\n\nIf no profiles are found in the vector store, return:\n{\n  \"user_id\": \"<input_user_id>\",\n  \"matches\": [],\n  \"error\": \"No profiles available in ix64 vector store for comparison\"\n}"
        }
      },
      "id": "46785359-19de-4b6b-8923-d91139b0413f",
      "name": "RAG AI Agent",
      "type": "@n8n/n8n-nodes-langchain.agent",
      "typeVersion": 1.6,
      "position": [
        2940,
        2360
      ]
    },
    {
      "parameters": {
        "operation": "text",
        "options": {}
      },
      "id": "76772fc0-deeb-4173-8594-05340b5e7ab3",
      "name": "Extract Document Text",
      "type": "n8n-nodes-base.extractFromFile",
      "typeVersion": 1,
      "position": [
        2800,
        3440
      ],
      "alwaysOutputData": true
    },
    {
      "parameters": {
        "topics": "test",
        "options": {}
      },
      "type": "n8n-nodes-base.mqttTrigger",
      "typeVersion": 1,
      "position": [
        2580,
        2360
      ],
      "id": "0cf0397a-063d-4b20-b1b9-fb389b117c72",
      "name": "MQTT Trigger",
      "credentials": {
        "mqtt": {
          "id": "2eEKpVKdJMJMTO8g",
          "name": "MQTT account"
        }
      }
    }
  ],
  "connections": {
    "Recursive Character Text Splitter": {
      "ai_textSplitter": [
        [
          {
            "node": "Default Data Loader",
            "type": "ai_textSplitter",
            "index": 0
          }
        ]
      ]
    },
    "Default Data Loader": {
      "ai_document": [
        [
          {
            "node": "Pinecone Vector Store",
            "type": "ai_document",
            "index": 0
          }
        ]
      ]
    },
    "Embeddings OpenAI": {
      "ai_embedding": [
        [
          {
            "node": "Pinecone Vector Store",
            "type": "ai_embedding",
            "index": 0
          }
        ]
      ]
    },
    "Pinecone Vector Store": {
      "main": [
        [
          {
            "node": "Loop Over Items",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Loop Over Items": {
      "main": [
        [],
        [
          {
            "node": "Pinecone Vector Store",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Google Drive1": {
      "main": [
        [
          {
            "node": "Extract Document Text",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Google Drive": {
      "main": [
        [
          {
            "node": "Google Drive1",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Embeddings OpenAI2": {
      "ai_embedding": [
        [
          {
            "node": "Pinecone Vector Store1",
            "type": "ai_embedding",
            "index": 0
          }
        ]
      ]
    },
    "OpenAI Chat Model1": {
      "ai_languageModel": [
        [
          {
            "node": "Answer questions with a vector store",
            "type": "ai_languageModel",
            "index": 0
          }
        ]
      ]
    },
    "Pinecone Vector Store1": {
      "ai_vectorStore": [
        [
          {
            "node": "Answer questions with a vector store",
            "type": "ai_vectorStore",
            "index": 0
          }
        ]
      ]
    },
    "Answer questions with a vector store": {
      "ai_tool": [
        [
          {
            "node": "RAG AI Agent",
            "type": "ai_tool",
            "index": 0
          }
        ]
      ]
    },
    "Window Buffer Memory": {
      "ai_memory": [
        [
          {
            "node": "RAG AI Agent",
            "type": "ai_memory",
            "index": 0
          }
        ]
      ]
    },
    "OpenAI Chat Model": {
      "ai_languageModel": [
        [
          {
            "node": "RAG AI Agent",
            "type": "ai_languageModel",
            "index": 0
          }
        ]
      ]
    },
    "RAG AI Agent": {
      "main": [
        []
      ]
    },
    "Extract Document Text": {
      "main": [
        [
          {
            "node": "Loop Over Items",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "MQTT Trigger": {
      "main": [
        [
          {
            "node": "RAG AI Agent",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "pinData": {},
  "meta": {
    "templateCredsSetupCompleted": true,
    "instanceId": "b7f3da10e55126a1317c18803d00b965733dd650296234a438415c26d285a04f"
  }
}

Share the output returned by the last node

Debug info

core

  • n8nVersion: 1.78.1
  • platform: docker (cloud)
  • nodeJsVersion: 20.18.2
  • database: sqlite
  • executionMode: regular
  • concurrency: 5
  • license: community

storage

  • success: all
  • error: all
  • progress: false
  • manual: true
  • binaryMode: filesystem

pruning

  • enabled: true
  • maxAge: 168 hours
  • maxCount: 2500 executions

client

  • userAgent: mozilla/5.0 (windows nt 10.0; win64; x64) applewebkit/537.36 (khtml, like gecko) chrome/133.0.0.0 safari/537.36
  • isTouchDevice: false

Generated at: 2025-02-24T15:48:50.222Z}

@Joffcom
Copy link
Member

Joffcom commented Feb 25, 2025

Hey @aeoniv,

We have created an internal ticket to look into this which we will be tracking as "GHC-956"

@Joffcom Joffcom added the in linear Issue or PR has been created in Linear for internal review label Feb 25, 2025
@Joffcom
Copy link
Member

Joffcom commented Feb 25, 2025

Are you getting an error when trying to auth? If there is no error maybe it is not an authentication issue and more of a connection issue.

@Joffcom Joffcom added the Needs Feedback Waiting for further input or clarification. label Feb 25, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
in linear Issue or PR has been created in Linear for internal review Needs Feedback Waiting for further input or clarification.
Projects
None yet
Development

No branches or pull requests

2 participants