Databricks and MQTT integration

Save yourself the work of writing custom integrations for Databricks and MQTT and use n8n instead. Build adaptable and scalable Data & Storage, workflows that work with your technology stack. All within a building experience you will love.

Get Started See n8n in action

How to connect Databricks and MQTT

Build your own Databricks and MQTT integration

Create custom Databricks and MQTT workflows by choosing triggers and actions. Nodes come with global operations and settings, as well as app-specific parameters that can be configured. You can also use the HTTP Request node to query data from any app or service with a REST API.

Databricks supported actions

Execute Query	Execute a SQL query and wait for results

Create Directory	Create a directory in volume
Delete Directory	Delete a directory in volume
Delete File	Delete a file from a volume
Download File	Download file content from a volume
Get File Metadata	Get file metadata from a volume
List Directory	List directory contents in volume
Upload File	Upload a file (up to 5 GiB) to Databricks volumes

Create Conversation Message	Create a new conversation message
Execute Message SQL Query	Execute a SQL query from a message attachment
Get Conversation Message	Get a conversation message by ID
Get Genie Space	Get details of a Genie space
Get Query Results	Get results of a SQL query execution
Start Conversation	Start a new conversation

Query Endpoint	Query a serving endpoint. The input format is automatically detected from the endpoint schema.

Create Catalog	Create a new catalog
Create Function	Create a new function
Create Table	Register a new table
Create Volume	Create a new volume
Delete Catalog	Delete a catalog
Delete Function	Delete a function
Delete Table	Delete a table
Delete Volume	Delete a volume
Get Catalog	Get catalog information
Get Function	Get function information
Get Table	Get table information
Get Volume	Get volume information
List Catalogs	List all catalogs
List Functions	List functions in schema
List Tables	List tables in schema
List Volumes	List volumes in schema
Update Catalog	Update catalog information

Create Index	Create a new vector search index
Get Index	Get details of a vector search index
List Indexes	List all vector search indexes
Query Index	Query a vector search index with text or vectors