- Inicio
- Recursos
- Integraciones
- Databricks
Integración Databricks n8nAutomatiza Databricks con n8n.
El dato ya está en el warehouse; lo caro es el rato que alguien pierde en buscarlo. La integración Databricks n8n reúne 36 operaciones y 6 recursos: consultas SQL, objetos de Unity Catalog, archivos de volumen, conversaciones de Genie y endpoints de model serving. No hay nodo trigger: el arranque llega de otro sitio.
Reseñas verificadas en Trustpilot · Agencia de IA, automatización y growth
¿Qué resuelve la integración Databricks n8n?
El nodo Databricks habla con la API REST de Databricks desde dentro de un flujo de trabajo. Lanza SQL contra un warehouse y espera las filas, lee y escribe archivos en volúmenes, gestiona objetos de Unity Catalog, conversa con un espacio de Genie y consulta endpoints de model serving. Un credential, es decir unas credenciales guardadas una sola vez en n8n, cubre las 36 operaciones y se reutiliza en cualquier flujo.
Los volúmenes suelen ser el primer terreno. Un archivo que llega por correo o desde un formulario entra en el flujo, files.createDirectory prepara la carpeta del periodo y el binario se escribe en el volumen para que un proceso posterior lo recoja. El mismo recurso lista un directorio, consulta los metadatos de un archivo o devuelve su contenido al flujo cuando hay que adjuntarlo a un correo. Nada de subidas manuales a mano.
El segundo terreno es el informe programado. Un Schedule Trigger salta a primera hora, databricksSql.executeQuery ejecuta la consulta contra el warehouse y espera el resultado, y las filas caen en una pestaña de Google Sheets, en una base de Airtable o en un canal de Slack. La consulta vive en el flujo, no en la pestaña del navegador de alguien.
Genie abre el tercero, y es el que cambia cómo pide datos la gente que no escribe SQL. Llega una pregunta, genie.startConversation abre el hilo en el espacio de Genie y el flujo vuelve a leer la respuesta. Si esa respuesta trae un adjunto SQL, el flujo ejecuta la sentencia y recoge las filas. Las repreguntas van al mismo hilo, así que el contexto no se pierde entre un mensaje y el siguiente.
Queda el model serving: el flujo monta una carga útil, consulta el endpoint y reparte la predicción. Lo que queda fuera de las operaciones del catálogo va por el nodo HTTP Request, que llama a cualquier endpoint de la API de Databricks reutilizando el mismo credential mediante la autenticación predefinida. Conviene saberlo antes de dibujar nada: Databricks no tiene nodo trigger en n8n, de modo que todo empieza con un Schedule Trigger, un Webhook de n8n al que llama un servicio externo, o el trigger de otra herramienta.
Si lo que estás valorando es la plataforma y no solo este nodo, la Reseña n8n entra en alojamiento y precios, y el Curso n8n monta flujos como estos desde cero.
¿Cómo se conecta Databricks con n8n?
- 01
Elige el método de autenticación
Hay dos caminos: el token de acceso personal, ligado a un usuario de Databricks, y OAuth2, que se presenta de dos formas. Con inicio de sesión en el navegador, conectas el credential entrando en Databricks: las operaciones corren con tus permisos y aparecen en los registros de auditoría con tu identidad, lo que Databricks recomienda para el uso interactivo. Con un service principal, n8n se autentica con client ID y secreto, sin nadie delante.
- 02
Rellena Host y el secreto
Todos los métodos parten de Host, la URL de tu espacio de trabajo, con esta forma:
https://adb-1234567890123456.7.azuredatabricks.net. Para un token, entra en el espacio de trabajo, pulsa tu nombre de usuario, luego Settings, luego Developer, luego Manage junto a Access tokens y después Generate new token. Copia el valor en ese momento, porque el diálogo no vuelve a mostrarlo, y pégalo en Access Token. Los tokens empiezan pordapi. - 03
Concede los privilegios de cada operación
La identidad del credential necesita siempre el entitlement Workspace access. Execute Query pide además el entitlement Databricks SQL access y CAN USE sobre el warehouse. Los datos de Unity Catalog exigen USE CATALOG en el catálogo, USE SCHEMA en el esquema y SELECT en las tablas o vistas, más EXECUTE para funciones y modelos. Genie necesita CAN RUN sobre el espacio y CAN USE sobre su warehouse SQL, y un endpoint de serving necesita CAN QUERY.
Qué sabe hacer el nodo Databricks
El nodo Databricks expone 36 operaciones en 6 recursos. Para cada una: el nodo tal como lo configuras en n8n, los campos obligatorios y nuestras notas de campo.
| Recurso | Create Catalog | Create Directory | Create Function | Create Index | Create Conversation Message | Create Table | Create Volume | Delete Catalog | Delete Directory | Delete File | Delete Function | Delete Table | Delete Volume | Download File | Execute Message SQL Query | Execute Query | Get Catalog | Get File Metadata | Get Function | Get Index | Get Conversation Message | Get Query Results | Get Genie Space | Get Table | Get Volume | List Catalogs | List Directory | List Functions | List Indexes | List Tables | List Volumes | Query Endpoint | Query Index | Start Conversation | Update Catalog | Upload File |
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| Databricks SQL | ✓ | |||||||||||||||||||||||||||||||||||
| File | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | |||||||||||||||||||||||||||||
| Genie | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ||||||||||||||||||||||||||||||
| Model Serving | ✓ | |||||||||||||||||||||||||||||||||||
| Unity Catalog | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ | |||||||||||||||||||
| Vector Search | ✓ | ✓ | ✓ | ✓ |
Índice de operaciones
Databricks SQL
1 operaciónExecute a SQL query
databricksSql.executeQueryLo que ves en n8n
Notas y casos de uso
Lanza SQL contra un warehouse y espera el resultado, de modo que el nodo siguiente recibe filas y no una referencia de trabajo.
Parámetros clave
- Warehouse: el warehouse SQL que ejecuta la sentencia, elegido de la lista o indicado por su identificador.
- Query: la sentencia en sí, del estilo
SELECT * FROM my_table LIMIT 10. - Query Parameters: valores con nombre que llamas en el SQL como
:name, para escribirWHERE ID = :user_iden vez de pegar el valor dentro de la cadena.
File
7 operacionesCreate a directory
files.createDirectoryLo que ves en n8n
Notas y casos de uso
Añade una carpeta dentro de un volumen. Es lo que hace un flujo antes de escribir archivos en una ruta que todavía no existe.
Parámetros clave
- Volume Path: el volumen de destino, con el formato
catalog.schema.volume. - Directory Path: dónde va la carpeta dentro de ese volumen, anidada como
folder1/subfoldery sin barra inicial.
Delete a directory
files.deleteDirectoryLo que ves en n8n
Notas y casos de uso
Borra una carpeta del volumen. Es la parte de limpieza de una rutina de exportación que, sin ella, acumula directorios sin fin.
Parámetros clave
- Volume Path: el volumen que contiene la carpeta, escrito
catalog.schema.volume. - Directory Path: la carpeta que se retira, relativa a la raíz del volumen y sin barra inicial.
Delete a file
files.deleteFileLo que ves en n8n
Notas y casos de uso
Elimina un único archivo de un volumen. Se indica por su ruta y no por un identificador, así que el flujo tiene que saber dónde lo dejó.
Parámetros clave
- Volume Path: el volumen afectado, con el formato
catalog.schema.volume. - File Path: el archivo dentro de ese volumen, por ejemplo
folder/file.txt, otra vez sin barra inicial.
Download a file
files.downloadFileLo que ves en n8n
Notas y casos de uso
Baja el contenido de un archivo guardado en un volumen y lo entrega al flujo como datos binarios, listos para reenviar, adjuntar o analizar.
Parámetros clave
- Volume Path: el volumen del que se lee, con el formato
catalog.schema.volume. - File Path: el archivo que se recupera, por ejemplo
folder/file.txt, sin barra inicial.
Get file info
files.getFileInfoLo que ves en n8n
Notas y casos de uso
Consulta los metadatos que Databricks guarda sobre un archivo, sin mover su contenido. La comprobación sale barata cuando al flujo solo le interesa saber si el archivo ya está.
Parámetros clave
- Volume Path: el volumen que se inspecciona, escrito
catalog.schema.volume. - File Path: el archivo que se busca, del tipo
folder/file.txt, sin barra inicial.
List a directory
files.listDirectoryLo que ves en n8n
Notas y casos de uso
Devuelve lo que hay en una ruta de volumen, un item por archivo, así que un flujo puede recorrer en bucle un lote que no ha generado él mismo.
Parámetros clave
- Volume Path: el volumen que se recorre, con el formato
catalog.schema.volume. - Directory Path: opcional; si lo dejas vacío se lista la raíz del volumen.
- Page Size y Page Token: cuántos archivos vuelven por página y el token que trae la siguiente.
Upload a file
files.uploadFileLo que ves en n8n
Notas y casos de uso
Escribe en un volumen los datos binarios que trae el item de entrada, para archivos de hasta 5 GiB.
Parámetros clave
- Volume Path: el volumen de destino, con el formato
catalog.schema.volume. - File Path: dónde aterriza el archivo dentro de él, por ejemplo
folder/file.txt. - Input Data Field Name: el nombre del campo del item de entrada que contiene los datos binarios.
- Overwrite: si un archivo ya existente en esa ruta se reemplaza o no.
Genie
6 operacionesCreate a conversation message
genie.createMessageLo que ves en n8n
Notas y casos de uso
Manda una pregunta de seguimiento a una conversación de Genie que ya está abierta, para que el intercambio conserve su contexto en lugar de empezar otra vez.
Parámetros clave
- Space ID: el espacio de Genie al que pertenece la conversación.
- Conversation ID: el hilo que se continúa, normalmente traído de un nodo anterior con una expresión del tipo
{{ $json.field }}. - Message: la pregunta, redactada como la haría un compañero.
Execute a message SQL query
genie.executeMessageQueryLo que ves en n8n
Notas y casos de uso
Cuando Genie responde con un adjunto SQL, esta operación ejecuta esa sentencia adjunta contra el warehouse del espacio.
Parámetros clave
- Space ID y Conversation ID: de qué espacio y de qué hilo procede la respuesta.
- Message ID: la respuesta que lleva el adjunto.
- Attachment ID: el adjunto concreto que se ejecuta, porque un mismo mensaje puede llevar varios.
Get a conversation message
genie.getMessageLo que ves en n8n
Notas y casos de uso
Vuelve a leer un mensaje concreto de una conversación. Es la vía por la que un flujo comprueba si Genie ya terminó de componer su respuesta.
Parámetros clave
- Space ID: el espacio de Genie implicado.
- Conversation ID: el hilo al que pertenece el mensaje.
- Message ID: el mensaje que se relee, referenciado desde un nodo anterior con una expresión como
{{ $json.field }}.
Get a Genie space
genie.getSpaceLo que ves en n8n
Notas y casos de uso
Describe un espacio de Genie, lo que permite a un flujo confirmar que apunta al correcto antes de ponerse a preguntarle cosas.
Parámetros clave
- Space ID: el único dato que pide esta operación, y el mismo valor que esperan todas las demás operaciones de Genie.
Get query results
genie.getQueryResultsLo que ves en n8n
Notas y casos de uso
Reúne las filas que produjo la ejecución SQL de un adjunto. Es el paso que por fin convierte una respuesta de Genie en datos utilizables.
Parámetros clave
- Space ID y Conversation ID: el espacio y el hilo que se consultan.
- Message ID: la respuesta cuya consulta se lanzó.
- Attachment ID: el adjunto del que quieres recuperar los resultados.
Start a conversation
genie.startConversationLo que ves en n8n
Notas y casos de uso
Abre un hilo nuevo en un espacio de Genie con una primera pregunta en lenguaje corriente. Todo lo demás del recurso Genie cuelga de la conversación que se crea aquí.
Parámetros clave
- Space ID: el espacio que va a responder.
- Initial Message: la pregunta de apertura, que puedes componer desde un nodo anterior con una expresión del tipo
{{ $json.field }}.
Model Serving
1 operaciónQuery a serving endpoint
modelServing.queryEndpointLo que ves en n8n
Notas y casos de uso
Envía una carga útil a un endpoint de model serving y devuelve lo que contesta el modelo. El nodo recupera el esquema OpenAPI del endpoint para deducir la URL de invocación y el formato de entrada esperado.
Parámetros clave
- Endpoint: el endpoint de serving que se consulta, elegido de la lista o indicado por su nombre.
- Request Body: la carga útil en JSON, validada en ejecución contra el esquema del endpoint, así que un cuerpo mal formado falla enseguida.
Unity Catalog
17 operacionesCreate a catalog
unityCatalog.createCatalogLo que ves en n8n
Notas y casos de uso
El catálogo es el contenedor más alto de Unity Catalog: dentro viven los esquemas y, dentro de ellos, las tablas. Esta operación registra uno nuevo en el workspace de Databricks.
Parámetros clave
- Catalog: el catálogo a usar, elegido en la lista del workspace o escrito a mano.
- Comment: una descripción opcional, con
Catalog descriptioncomo texto de ejemplo en el campo. Se agradece cuando varios equipos comparten el mismo workspace.
Create a function
unityCatalog.createFunctionLo que ves en n8n
Notas y casos de uso
Registrar una función SQL pone una expresión reutilizable a disposición de todo lo que consulta ese esquema.
Parámetros clave
- Catalog y Schema: dónde queda la función, ambos tomados de las listas del workspace.
- Function Name: su nombre, al estilo de
my_function. - Input Parameters: un array JSON en el que cada parámetro lleva
name,type_nameytype_text. - Return Type: el tipo que devuelve, por ejemplo
STRING,INToDOUBLE. - Routine Body: el lenguaje del cuerpo de la función. Routine Definition: el cuerpo en sí, una expresión SQL del tipo
RETURN x + 1.
Create a table
unityCatalog.createTableLo que ves en n8n
Notas y casos de uso
Crear una tabla aquí significa declarar una ruta de almacenamiento ya existente. La API Create Table solo admite tablas Delta externas, así que el dato está en su sitio antes de que corra el paso.
Parámetros clave
- Catalog, Schema: la pareja que ubica la nueva tabla.
- Table Name: el nombre registrado, al estilo de
my_table. - Storage Location: la URL raíz del almacenamiento externo, por ejemplo
s3://my-bucket/path/to/table. - Columns, dentro de Additional Fields: un array JSON de definiciones de columna, cada una con nombre y un
type_nameentreSTRING,LONG,DOUBLE,BOOLEAN,DATEoTIMESTAMP.
Create a volume
unityCatalog.createVolumeLo que ves en n8n
Notas y casos de uso
Los volúmenes son el sitio de Unity Catalog pensado para ficheros y no para filas. Declarar uno da destino gobernado a los pasos que mueven archivos.
Parámetros clave
- Catalog, Schema: los dos niveles a los que pertenece el volumen.
- Volume Name: el nombre del volumen, del tipo
my_volume. - Volume Type: con
MANAGED, Databricks gestiona el almacenamiento; conEXTERNAL, el volumen apunta a un almacenamiento externo. - Storage Location, dentro de Additional Fields: la ubicación de almacenamiento externo, obligatoria para los volúmenes
EXTERNAL.
Delete a catalog
unityCatalog.deleteCatalogLo que ves en n8n
Notas y casos de uso
Borrar un catálogo retira el contenedor más amplio de Unity Catalog, el que sostiene los esquemas. Por eso es el borrado que merece una aprobación manual delante.
Parámetros clave
- Catalog: el catálogo a usar, seleccionado en la lista o pasado con una expresión como
{{ $json.field }}cuando el nombre viene de un nodo anterior.
Delete a function
unityCatalog.deleteFunctionLo que ves en n8n
Notas y casos de uso
Una función SQL sustituida por otra más reciente deja de tener sentido. La operación retira la definición antigua de su esquema.
Parámetros clave
- Catalog, Schema: el lugar donde se registró la función.
- Function: la función en cuestión, seleccionada en el resource locator y no escrita como una etiqueta suelta.
Delete a table
unityCatalog.deleteTableLo que ves en n8n
Notas y casos de uso
El borrado quita el registro de la tabla en Unity Catalog. La tabla se identifica por su sitio en la jerarquía y nunca por el nombre solo, de ahí que los tres campos vayan juntos.
Parámetros clave
- Catalog y Schema: los dos niveles por encima de la tabla.
- Table: la tabla en cuestión, elegida entre las del esquema.
Delete a volume
unityCatalog.deleteVolumeLo que ves en n8n
Notas y casos de uso
Un volumen que ya no cumple ninguna función se retira desde aquí. El nodo espera el nombre del volumen, no la ruta de almacenamiento que hay detrás.
Parámetros clave
- Catalog, Schema: el contenedor en el que vive el volumen.
- Volume Name: el nombre del volumen, por ejemplo
my_volume.
Get a catalog
unityCatalog.getCatalogLo que ves en n8n
Notas y casos de uso
La información de un catálogo vuelve como un único item sobre el que el flujo puede bifurcar antes de escribir nada dentro.
Parámetros clave
- Catalog: el catálogo a usar. Encadena un nodo IF para decidir el camino según lo que devuelva la lectura.
Get a function
unityCatalog.getFunctionLo que ves en n8n
Notas y casos de uso
Antes de que un flujo se apoye en una función SQL, releer su definición registrada muestra qué espera de entrada y qué devuelve.
Parámetros clave
- Catalog, Schema: dónde buscar.
- Function: la función en cuestión, resuelta mediante el resource locator.
Get a table
unityCatalog.getTableLo que ves en n8n
Notas y casos de uso
La información de una tabla son sus características declaradas, no las filas que contiene. Es lo que lee un paso que necesita saber con qué está tratando.
Parámetros clave
- Catalog y Schema: el camino hasta la tabla.
- Table: la tabla en cuestión, tomada del resource locator.
{{ $json.field }} alimentando el nodo siguiente.Get a volume
unityCatalog.getVolumeLo que ves en n8n
Notas y casos de uso
Comprobar un volumen antes de dejar ficheros dentro evita una ejecución que falla a mitad de camino. La operación devuelve la información de ese volumen.
Parámetros clave
- Catalog, Schema: los dos nombres que enmarcan la búsqueda.
- Volume Name: el volumen en sí, del tipo
my_volume.
List catalogs
unityCatalog.listCatalogsLo que ves en n8n
Notas y casos de uso
Todos los catálogos que ve el credential, es decir la identidad con la que se conecta n8n a Databricks, vuelven en una sola llamada y sin un solo campo que rellenar. Es el arranque natural cuando el flujo trabaja a escala de workspace y no sobre un catálogo conocido de antemano.
List functions
unityCatalog.listFunctionsLo que ves en n8n
Notas y casos de uso
Las funciones se acumulan sin hacer ruido. La operación lista lo que hay registrado y, como los dos filtros son opcionales, una llamada sin filtros abarca más que un solo esquema.
Parámetros clave
- Catalog: filtra por catálogo, opcional.
- Schema: filtra por esquema, opcional, y necesita que haya un catálogo indicado al lado.
List tables
unityCatalog.listTablesLo que ves en n8n
Notas y casos de uso
Las tablas registradas en un esquema llegan como items, una por tabla, listas para recorrer en bucle. Dejar los dos filtros vacíos amplía la llamada en lugar de acotarla.
Parámetros clave
- Catalog: filtro opcional sobre el catálogo.
- Schema: filtro opcional sobre el esquema, que solo se aplica cuando ya hay un catálogo elegido.
List volumes
unityCatalog.listVolumesLo que ves en n8n
Notas y casos de uso
Toda revisión de almacenamiento empieza por saber qué existe. La operación devuelve los volúmenes declarados en un esquema, así el flujo itera sobre ellos en vez de llevar los nombres escritos a fuego.
Parámetros clave
- Catalog: opcional, restringe el listado a un catálogo.
- Schema: opcional, y necesita un catálogo indicado junto a él.
Update a catalog
unityCatalog.updateCatalogLo que ves en n8n
Notas y casos de uso
Los metadatos de un catálogo envejecen rápido cuando los equipos cambian, y la actualización toca solo esa información, sin tocar lo que hay dentro del catálogo.
Parámetros clave
- Catalog: el catálogo a usar, aquí el que se está actualizando.
- Comment: la descripción opcional, con
Catalog descriptioncomo texto de ejemplo. Es la parte que los equipos mantienen de verdad al día.
Vector Search
4 operacionesCreate a vector search index
vectorSearch.createIndexLo que ves en n8n
Notas y casos de uso
Cualquier montaje de búsqueda vectorial arranca por el índice, que pertenece a un endpoint.
Parámetros clave
- Index Name y Endpoint Name: el índice que se crea y el endpoint de búsqueda vectorial que lo aloja.
- Primary Key: la columna de clave primaria del índice, con
IDcomo ejemplo en el campo. - Index Type:
DELTA_SYNCse sincroniza automáticamente con una tabla Delta de origen,DIRECT_ACCESSadmite lectura y escritura directa de vectores y metadatos. - Delta Sync Index Spec y Direct Access Index Spec: la especificación JSON propia de cada uno de esos dos tipos.
Get a vector search index
vectorSearch.getIndexLo que ves en n8n
Notas y casos de uso
El detalle de un índice responde a la pregunta que se hace un flujo justo antes de buscar: ¿está ese índice donde debería? Con un solo campo basta.
Parámetros clave
- Index Name: el nombre del índice de búsqueda vectorial, escrito a mano o traído de un nodo anterior con una expresión como
{{ $json.field }}.
List vector search indexes
vectorSearch.listIndexesLo que ves en n8n
Notas y casos de uso
Un mismo endpoint puede sostener varios índices. La operación los devuelve todos, acotados al endpoint que indicas, lo que mantiene el resultado legible incluso en un workspace cargado.
Parámetros clave
- Endpoint Name: el endpoint de búsqueda vectorial cuyos índices quieres listar.
Query a vector search index
vectorSearch.queryIndexLo que ves en n8n
Notas y casos de uso
La búsqueda semántica sale de esta operación, desde texto en bruto o desde vectores calculados antes.
Parámetros clave
- Query Type: con
text, Databricks convierte tu Query Text en vectores; convector, sale a buscar el Query Vector que aportas. - Index Name: el índice consultado.
- Columns to Return: la lista de columnas a devolver, separadas por comas, del tipo
content, url. - Search Mode:
HYBRIDcombina búsqueda semántica y por palabras clave,ANNse queda en similitud vectorial pura. - Score Threshold, dentro de Options: la puntuación mínima de relevancia, entre
0y1.
¿Necesitas ayuda para automatizar Databricks con n8n?
El equipo te responde directamente.
Cada mensaje lo lee una persona.
Databricks y n8n, lo que se pregunta después
01¿La integración Databricks n8n es gratuita?
02¿Qué credenciales y qué permisos hacen falta?
03¿Qué límites tiene el nodo Databricks?
04¿Puede un flujo reaccionar a algo que pasa en Databricks?
05¿n8n o Make para Databricks?
Recibe nuestros tips de integración cada semana.
Sin spam. Cancela cuando quieras.



