Resources · n8n integration

Databricks n8n integrationAutomate Databricks with n8n.

Your warehouse knows the answer, so why is someone still opening a notebook to fetch it? The Databricks n8n integration packs 36 operations across 6 resources: SQL queries, Unity Catalog objects, volume files, Genie conversations and model serving. No trigger node ships with it: a schedule or an app starts the run.

Verified Trustpilot reviews · AI, automation & growth agency

Why automate

What does the Databricks n8n integration actually do?

The Databricks node talks to the Databricks REST API from inside a workflow. It runs SQL on a warehouse and waits for the rows, reads and writes files in volumes, manages Unity Catalog objects, holds conversations with a Genie space, and sends payloads to model serving endpoints. One credential, created once in n8n, covers all 36 operations and gets reused in every workflow that needs the workspace.

Scheduled reporting is the obvious first job. A Schedule Trigger fires at seven, databricksSql.executeQuery runs the statement against the warehouse and waits for the result, and the rows go straight into a Google Sheets tab or a Slack channel. Nobody logs in to copy a table. The query is versioned in the workflow, not in someone's browser tab.

The second job is Genie, and it is the one that changes how non-technical teammates ask for data. A question arrives in a chat message, genie.startConversation opens the thread in a Genie space, and the workflow reads the reply back. When Genie answers with a SQL attachment, the workflow runs that statement and collects the rows. Follow-up questions go to the same conversation, so context survives from one message to the next.

Volumes cover the file side. A document dropped in Google Drive gets picked up, files.createDirectory prepares a folder for the month, and the binary is written into the volume for a downstream job to pick up. The same resource lists a directory, reads a file's metadata and downloads content back into the workflow when a report needs to be attached to an email.

Model serving is the fourth angle: a workflow assembles a payload, queries the endpoint and routes the prediction wherever it belongs. What no operation in the catalog covers goes through the HTTP Request node, which calls any Databricks API endpoint while reusing the same credential through predefined authentication. Worth knowing before you plan the build: Databricks has no trigger node in n8n, so every workflow starts with a Schedule Trigger, an n8n Webhook called by another service, or the trigger of a different app.

If you are weighing the platform itself rather than this one node, the n8n review covers hosting and pricing in detail, and the n8n training walks through building workflows like these from scratch.

Connect

How do you connect Databricks to n8n?

  1. 01

    Choose an authentication method

    Two methods exist: a personal access token, tied to one Databricks user, and OAuth2, which itself comes in two shapes. With user login you sign in to Databricks in the browser, operations run with your permissions and show up in audit logs under your identity, the shape Databricks recommends for attended work. With a service principal, n8n authenticates using a client ID and secret without anyone present.

  2. 02

    Fill in Host and the secret

    Every method starts with Host, the URL of your workspace, in the shape https://adb-1234567890123456.7.azuredatabricks.net. For a token, open your workspace, select your username, then Settings, then Developer, then Manage next to Access tokens, then Generate new token. A comment helps you recognize it later. Copy the value immediately, because the dialog never shows it again, and paste it into Access Token. Tokens start with dapi.

  3. 03

    Grant the privileges the operations need

    Whichever identity the credential authenticates as needs the Workspace access entitlement first. Execute Query also needs the Databricks SQL access entitlement and CAN USE on the warehouse. Unity Catalog data needs USE CATALOG on the catalog, USE SCHEMA on the schema and SELECT on the tables or views, plus EXECUTE for functions and models. Genie needs CAN RUN on the space and CAN USE on its SQL warehouse, and a serving endpoint needs CAN QUERY.

Actions

What can the Databricks node do?

The Databricks node exposes 36 operations across 6 resources. For each one: the node as you configure it in n8n, the required fields, and our field notes.

Resources × operations matrix
ResourceCreate CatalogCreate DirectoryCreate FunctionCreate IndexCreate Conversation MessageCreate TableCreate VolumeDelete CatalogDelete DirectoryDelete FileDelete FunctionDelete TableDelete VolumeDownload FileExecute Message SQL QueryExecute QueryGet CatalogGet File MetadataGet FunctionGet IndexGet Conversation MessageGet Query ResultsGet Genie SpaceGet TableGet VolumeList CatalogsList DirectoryList FunctionsList IndexesList TablesList VolumesQuery EndpointQuery IndexStart ConversationUpdate CatalogUpload File
Databricks SQL
File
Genie
Model Serving
Unity Catalog
Vector Search

Databricks SQL

1 operation
01

Execute a SQL query

databricksSql.executeQuery

What you see in n8n

Notes & use cases

Runs SQL on a warehouse and waits for the result, so the next node receives rows rather than a job reference.

Key parameters

  • Warehouse: the SQL warehouse that executes the statement, chosen from the list or given by its ID.
  • Query: the statement itself, along the lines of SELECT * FROM my_table LIMIT 10.
  • Query Parameters: named values you reference in the SQL as :name, so a workflow sends WHERE ID = :user_id instead of gluing a value into the string.
Use cases
a daily revenue rollup that feeds a morning digest, with yesterday's date passed as a named parameter.

File

7 operations
02

Create a directory

files.createDirectory

What you see in n8n

Notes & use cases

Adds a folder inside a volume, which is what a workflow does before writing files into a path that does not exist yet.

Key parameters

  • Volume Path: the volume in the format catalog.schema.volume.
  • Directory Path: where the folder goes inside that volume, nested like folder1/subfolder, with no leading slash.
Use cases
opening a fresh folder per month at the start of an export run, so the files that follow have somewhere predictable to land.
03

Delete a directory

files.deleteDirectory

What you see in n8n

Notes & use cases

Removes a folder from a volume, the cleanup half of an export routine that would otherwise pile up folders forever.

Key parameters

  • Volume Path: the volume that holds the folder, written catalog.schema.volume.
  • Directory Path: the folder to remove, relative to the volume root and without a leading slash.
Use cases
a monthly housekeeping workflow that drops last quarter's staging folders once the data has been archived elsewhere.
04

Delete a file

files.deleteFile

What you see in n8n

Notes & use cases

Deletes a single file from a volume. The file is addressed by its path, not by an identifier, so the workflow has to know where it put it.

Key parameters

  • Volume Path: the target volume, in the format catalog.schema.volume.
  • File Path: the file inside that volume, such as folder/file.txt, again with no leading slash.
Use cases
removing a raw CSV after a workflow has loaded it, so the volume keeps only the processed output.
05

Download a file

files.downloadFile

What you see in n8n

Notes & use cases

Pulls the content of a file out of a volume and hands it to the workflow as binary data, ready to attach, forward or parse.

Key parameters

  • Volume Path: the volume to read from, in the format catalog.schema.volume.
  • File Path: the file to fetch, for example folder/file.txt, without a leading slash.
Use cases
retrieving a generated PDF report from the volume and sending it as an email attachment to the finance team.
06

Get file info

files.getFileInfo

What you see in n8n

Notes & use cases

Reads the metadata Databricks holds about a file, without moving its content. That keeps a check cheap when a workflow only needs to know whether the file exists yet.

Key parameters

  • Volume Path: the volume to inspect, written catalog.schema.volume.
  • File Path: the file to look up, such as folder/file.txt, with no leading slash.
Use cases
a guard step that confirms last night's export landed before the rest of the workflow starts processing it.
07

List a directory

files.listDirectory

What you see in n8n

Notes & use cases

Returns what sits inside a volume path, one item per file, which is how a workflow loops over a batch it did not create itself.

Key parameters

  • Volume Path: the volume to browse, in the format catalog.schema.volume.
  • Directory Path: optional; leave it empty to list the volume root.
  • Page Size and Page Token: how many files come back per page, and the token that fetches the next one.
Use cases
walking a landing folder each morning and processing every file dropped there overnight.
08

Upload a file

files.uploadFile

What you see in n8n

Notes & use cases

Writes binary data carried by the incoming item into a volume, for files up to 5 GiB.

Key parameters

  • Volume Path: the destination volume, in the format catalog.schema.volume.
  • File Path: where the file lands inside it, such as folder/file.txt.
  • Input Data Field Name: the name of the field on the incoming item that holds the binary data.
  • Overwrite: whether an existing file at that path gets replaced.
Use cases
pushing a supplier spreadsheet received by email into a volume so a scheduled job can ingest it.

Genie

6 operations
09

Create a conversation message

genie.createMessage

What you see in n8n

Notes & use cases

Sends a follow-up question into a Genie conversation that is already open, so the exchange keeps its context instead of starting over.

Key parameters

  • Space ID: the Genie space the conversation belongs to.
  • Conversation ID: the thread to continue, usually carried over from an earlier node with an expression such as {{ $json.field }}.
  • Message: the question, written the way a colleague would ask it.
Use cases
a chat bot that relays each new question from a team channel into the same Genie thread.
10

Execute a message SQL query

genie.executeMessageQuery

What you see in n8n

Notes & use cases

Genie answers a question with a SQL attachment; this operation runs that attached statement against the space's warehouse.

Key parameters

  • Space ID and Conversation ID: which space and which thread the answer came from.
  • Message ID: the answer that carries the attachment.
  • Attachment ID: the specific attachment to execute, since one message can hold more than one.
Use cases
turning an analyst's plain-language question into an executed query without anyone writing the SQL by hand.
11

Get a conversation message

genie.getMessage

What you see in n8n

Notes & use cases

Reads a single message back from a conversation, which is how a workflow checks whether Genie has finished composing its answer.

Key parameters

  • Space ID: the Genie space in play.
  • Conversation ID: the thread the message belongs to.
  • Message ID: the message to read, referenced from an earlier node with an expression like {{ $json.field }}.
Use cases
a wait-and-check loop that only forwards the reply to Slack once Genie has actually produced one.
12

Get a Genie space

genie.getSpace

What you see in n8n

Notes & use cases

Describes a Genie space, so a workflow can confirm it is pointing at the right one before it starts asking questions of it.

Key parameters

  • Space ID: the only thing this operation needs, and the same value every other Genie operation expects.
Use cases
a setup workflow that reads the space details once and stores them, so the rest of the team can pick a space by name rather than pasting an identifier into every node.
13

Get query results

genie.getQueryResults

What you see in n8n

Notes & use cases

Collects the rows produced by an attachment's SQL execution, which is the step that finally turns a Genie answer into usable data.

Key parameters

  • Space ID and Conversation ID: the space and thread being read.
  • Message ID: the answer whose query was run.
  • Attachment ID: the attachment whose results you want back.
Use cases
pushing the numbers behind a Genie answer into a spreadsheet, so the team gets the table and not just the sentence.
14

Start a conversation

genie.startConversation

What you see in n8n

Notes & use cases

Opens a new thread in a Genie space with a first question in plain language. Everything else in the Genie resource hangs off the conversation this creates.

Key parameters

  • Space ID: the space that will answer.
  • Initial Message: the opening question, which you can build from an earlier node with an expression such as {{ $json.field }}.
Use cases
a form submission that opens one conversation per request, keeping each requester's follow-ups separate.

Model Serving

1 operation
15

Query a serving endpoint

modelServing.queryEndpoint

What you see in n8n

Notes & use cases

Sends a payload to a model serving endpoint and returns what the model answers. The node fetches the endpoint's OpenAPI schema to work out the right invocation URL and the expected input format.

Key parameters

  • Endpoint: the serving endpoint to query, picked from the list or given by name.
  • Request Body: the JSON payload, validated against the endpoint schema at runtime, so a malformed body fails fast.
Use cases
scoring each new lead as it arrives and routing the high scores to a sales owner.

Unity Catalog

17 operations
16

Create a catalog

unityCatalog.createCatalog

What you see in n8n

Notes & use cases

A catalog sits at the top of the Unity Catalog hierarchy, above schemas and tables. This operation registers a new one in the workspace, so later steps have somewhere governed to write.

Key parameters

  • Catalog: the catalog to use, picked from the workspace list or typed in as a name.
  • Comment: an optional description, and the placeholder suggests Catalog description. Worth filling in when several teams share the same workspace.
Use cases
a data team that spins up one catalog per environment, created from a workflow instead of by hand in the Databricks UI.
17

Create a function

unityCatalog.createFunction

What you see in n8n

Notes & use cases

Registering a SQL function makes a reusable expression available to everything that queries the schema. The node creates it from the definition passed in.

Key parameters

  • Catalog and Schema: where the function lands, both chosen from the workspace lists.
  • Function Name: the name it gets, along the lines of my_function.
  • Input Parameters: a JSON array where each parameter carries name, type_name and type_text.
  • Return Type: what the function gives back, such as STRING, INT or DOUBLE.
  • Routine Body: the language of the body. Routine Definition: the body itself, a SQL expression in the style of RETURN x + 1.
Use cases
shipping a shared currency conversion helper to analysts without anyone opening a notebook.
18

Create a table

unityCatalog.createTable

What you see in n8n

Notes & use cases

Registration here means declaring a storage path as a table. The Create Table API only supports external Delta tables, so the data already lives somewhere when this step runs.

Key parameters

  • Catalog, Schema: the pair that scopes the new table.
  • Table Name: the registered name, in the style of my_table.
  • Storage Location: the external storage root URL, for instance s3://my-bucket/path/to/table.
  • Columns, in Additional Fields: a JSON array of column definitions, each with a name and a type_name among STRING, LONG, DOUBLE, BOOLEAN, DATE or TIMESTAMP.
Use cases
a nightly export dropped into object storage and registered as a table the moment the file lands.
19

Create a volume

unityCatalog.createVolume

What you see in n8n

Notes & use cases

Volumes are the Unity Catalog home for files rather than rows. Declaring one gives file steps a governed destination.

Key parameters

  • Catalog, Schema: the parents the volume belongs to.
  • Volume Name: the name of the volume, such as my_volume.
  • Volume Type: with MANAGED, Databricks manages the storage; with EXTERNAL, the volume points at storage you already own.
  • Storage Location, in Additional Fields: the external storage location, required for EXTERNAL volumes.
Use cases
one volume per client for incoming PDF invoices, created as soon as that client is onboarded.
20

Delete a catalog

unityCatalog.deleteCatalog

What you see in n8n

Notes & use cases

Taking a catalog out removes the widest container in Unity Catalog, the one that holds the schemas. That makes it the delete worth putting a manual approval step in front of.

Key parameters

  • Catalog: the catalog to use, selected in the list or passed as an expression such as {{ $json.field }} when the name comes from an earlier node.
Use cases
tearing down the sandbox catalog a training session created, once the session is over and the attendees have left.
21

Delete a function

unityCatalog.deleteFunction

What you see in n8n

Notes & use cases

When a SQL function has been superseded, this removes the old definition from its schema so queries stop resolving to it.

Key parameters

  • Catalog, Schema: the location the function was registered in.
  • Function: the function to access, selected in the resource locator rather than typed as a bare label.
Use cases
a deployment workflow that drops the previous version of a helper function, then registers the new one in the same run.
22

Delete a table

unityCatalog.deleteTable

What you see in n8n

Notes & use cases

Dropping a table removes its registration from Unity Catalog. The table is identified by its place in the hierarchy, not by a name on its own, so the three fields work together.

Key parameters

  • Catalog and Schema: the two levels above the table.
  • Table: the table to access, chosen among the tables of that schema.
Use cases
housekeeping on a Schedule Trigger, clearing the staging tables an interrupted load left behind.
23

Delete a volume

unityCatalog.deleteVolume

What you see in n8n

Notes & use cases

Volumes that have outlived their purpose come off here. The node wants the volume name, not the storage path sitting behind it.

Key parameters

  • Catalog, Schema: the container the volume sits in.
  • Volume Name: the name of the volume, for example my_volume.
Use cases
closing an account and removing the volume that held its uploaded files, as the last step of an offboarding flow.
24

Get a catalog

unityCatalog.getCatalog

What you see in n8n

Notes & use cases

Catalog information comes back as a single item you can branch on, which is what a workflow needs before it starts writing into that catalog.

Key parameters

  • Catalog: the catalog to use. Follow it with an IF node to branch on what the lookup returns.
Use cases
a guard step at the top of a nightly pipeline, checking the target catalog before any of the load steps run.
25

Get a function

unityCatalog.getFunction

What you see in n8n

Notes & use cases

Before a workflow leans on a SQL function, reading back its registered definition shows what the function expects and what it returns.

Key parameters

  • Catalog, Schema: where to look.
  • Function: the function to access, resolved through the resource locator.
Use cases
documenting what a finance schema exposes, one item per function pushed into a spreadsheet at the end of the run.
26

Get a table

unityCatalog.getTable

What you see in n8n

Notes & use cases

Table information is what a downstream step reads when it needs the registered details of a table rather than the rows inside it.

Key parameters

  • Catalog and Schema: the path down to the table.
  • Table: the table to access, picked in the resource locator.
Use cases
an audit flow that walks a schema and records what each table declares, with a generic expression such as {{ $json.field }} feeding the next node.
27

Get a volume

unityCatalog.getVolume

What you see in n8n

Notes & use cases

Checking a volume first saves a run that would otherwise fail halfway through an upload. The operation returns that volume's information.

Key parameters

  • Catalog, Schema: the two names that scope the lookup.
  • Volume Name: the volume itself, such as my_volume.
Use cases
a file ingestion workflow that confirms the destination volume is in place before the first file moves, and routes the batch to a review queue when it is not.
28

List catalogs

unityCatalog.listCatalogs

What you see in n8n

Notes & use cases

Every catalog the credential can see comes back in one call, with no field to fill in at all. That makes it the natural opening move when a workflow has to work across a whole workspace instead of one catalog it already knows about.

Use cases
a weekly inventory that lists the catalogs, loops over them and writes the result into a shared sheet for whoever owns data governance.
29

List functions

unityCatalog.listFunctions

What you see in n8n

Notes & use cases

Functions pile up quietly in a schema. This returns what is registered, and since both filters are optional, an unfiltered call reaches wider than a single schema.

Key parameters

  • Catalog: filters by catalog, optional.
  • Schema: filters by schema, optional, and it requires a catalog to be set alongside it.
Use cases
prep for a review meeting, pulling the function list of the analytics schema into a Slack message the morning it happens.
30

List tables

unityCatalog.listTables

What you see in n8n

Notes & use cases

The tables registered in a schema arrive as items, one per table, ready to loop over. Leaving both filters empty widens the call rather than narrowing it.

Key parameters

  • Catalog: an optional filter on the catalog.
  • Schema: an optional filter on the schema, which only applies once a catalog is chosen.
Use cases
a self-refreshing catalog page for the analytics team, rebuilt on a schedule so new tables show up without anyone editing a document.
31

List volumes

unityCatalog.listVolumes

What you see in n8n

Notes & use cases

Storage reviews start with knowing what exists. The operation returns the volumes declared in a schema, so a workflow iterates over them instead of hardcoding names.

Key parameters

  • Catalog: optional, restricts the listing to one catalog.
  • Schema: optional, and it needs a catalog set next to it.
Use cases
a quarterly check that lists the volumes of each schema and emails the result to the person responsible for that schema.
32

Update a catalog

unityCatalog.updateCatalog

What you see in n8n

Notes & use cases

Catalog metadata drifts as teams change. Updating it touches the catalog's own information and leaves everything inside untouched.

Key parameters

  • Catalog: the catalog to use, meaning the one being updated.
  • Comment: the optional description, shown with the placeholder Catalog description. It is the piece teams actually keep current.
Use cases
a flow started from a ticketing tool that rewrites the catalog description whenever the owning team changes hands.

Vector Search

4 operations
33

Create a vector search index

vectorSearch.createIndex

What you see in n8n

Notes & use cases

Index creation is where a vector search setup begins: the index is what queries hit later, and it belongs to an endpoint.

Key parameters

  • Index Name and Endpoint Name: the index being created and the vector search endpoint it lives on.
  • Primary Key: the primary key column of the index, shown with the placeholder ID.
  • Index Type: DELTA_SYNC syncs automatically with a source Delta table, DIRECT_ACCESS supports direct read and write of vectors and metadata.
  • Delta Sync Index Spec and Direct Access Index Spec: the JSON specification for each of those two types.
Use cases
standing up the index behind an internal help assistant, from the same workflow that prepares its source table.
34

Get a vector search index

vectorSearch.getIndex

What you see in n8n

Notes & use cases

Index details answer the question a workflow asks right before it searches: is this index actually there? One field is all it takes.

Key parameters

  • Index Name: the name of the vector search index, typed in or handed over from a previous node with an expression like {{ $json.field }}.
Use cases
a check placed in front of a retrieval step, so a support assistant never fires a query at an index that is not in place.
35

List vector search indexes

vectorSearch.listIndexes

What you see in n8n

Notes & use cases

One endpoint can host several indexes. This returns them all, scoped to the endpoint you name, which keeps the result readable even in a busy workspace.

Key parameters

  • Endpoint Name: the vector search endpoint whose indexes you want listed.
Use cases
a morning monitoring workflow that lists what sits on the production endpoint and posts the result to a team channel.
36

Query a vector search index

vectorSearch.queryIndex

What you see in n8n

Notes & use cases

Semantic search over an index runs from this operation, either from raw text or from embeddings computed upstream.

Key parameters

  • Query Type: text has Databricks convert your Query Text into vectors, vector sends the Query Vector you supply.
  • Index Name: the index being searched.
  • Columns to Return: a comma separated list of column names, like content, url.
  • Search Mode: HYBRID mixes semantic and keyword search, ANN stays on pure vector similarity.
  • Score Threshold, in Options: a minimum relevance score, between 0 and 1.
Use cases
pulling the closest documentation passages before an AI step drafts a reply to a customer question.
Need help

Need help automating Databricks with n8n?

A person reads every message.

FAQ

Databricks and n8n, the questions that come up next

01Is the Databricks n8n integration free to use?
On the n8n side, yes. The Databricks node ships with n8n, so there is nothing to install and nothing extra to pay for it, whether you run n8n Cloud or a self-hosted instance of the Community Edition under the Sustainable Use license. A workflow behaves the same way in both places. The credential you create is also free to reuse: you set it up once in the Credentials menu and every workflow that touches the workspace picks it from a dropdown. What your Databricks workspace itself costs is a separate question and depends on your own agreement, so check that on the Databricks side rather than here.
02What credentials and privileges do you need?
The node accepts a personal access token or OAuth2. A token is tied to one Databricks user and pairs a Host, the URL of your workspace, with the token value itself, which starts with dapi. OAuth2 comes either as a browser sign-in, where operations run with your own permissions and appear in audit logs under your identity, or as a service principal with a client ID and secret for unattended runs. On top of that, the identity needs privileges: the Workspace access entitlement for everything, Databricks SQL access plus CAN USE on the warehouse for Execute Query, CAN RUN on a Genie space, and CAN QUERY on a serving endpoint.
03What are the limits of the Databricks node?
The node covers 36 operations spread over 6 resources. Anything that falls outside those operations goes through the HTTP Request node, which calls any endpoint of the Databricks API and reuses the very same credential through predefined authentication, so you do not manage a second secret. Listing a directory in a volume is paginated: Page Size sets how many files come back at once and Page Token fetches the next page, which matters when a volume holds more files than one call returns. Uploading is bounded too, at 5 GiB per file.
04Can a workflow react to something happening in Databricks?
Not from Databricks itself. There is no Databricks trigger node in n8n, so a workflow that involves the workspace has to start somewhere else. Three options cover almost every case. A Schedule Trigger runs the workflow at a fixed interval, which suits nightly queries and morning digests. An n8n Webhook, meaning a URL that n8n exposes and another service calls, starts the run the moment that service has something to say. Or the trigger of another app in the same workflow, such as a new row or a new message, kicks things off and the Databricks node runs after it.
05n8n or Make for Databricks?
It comes down to where the platform runs and how it is billed. Make is hosted by Make, with no self-hosting option, and it charges per operation, so a workflow that loops over a large result set costs more as it grows. n8n runs on n8n Cloud or on your own infrastructure through Docker or npm, and a workflow is identical either way. That matters for Databricks in particular, because query results are often the kind of data a team would rather keep inside its own network. If you build visually and never want to think about servers, Make is the lighter path.
Hack'celeration Lab

Get our weekly integration tips.

No spam. Unsubscribe anytime.