Recursos · Integración n8n

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

Por qué automatizar

¿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.

Conexión

¿Cómo se conecta Databricks con n8n?

  1. 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.

  2. 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 por dapi.

  3. 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.

Acciones

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.

Matriz recursos × operaciones
RecursoCreate 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 operación
01

Execute a SQL query

databricksSql.executeQuery

Lo 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 escribir WHERE ID = :user_id en vez de pegar el valor dentro de la cadena.
Casos de uso
el recuento de altas de la semana, con la fecha entrando como parámetro con nombre.

File

7 operaciones
02

Create a directory

files.createDirectory

Lo 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/subfolder y sin barra inicial.
Casos de uso
abrir una carpeta por cliente al arrancar una exportación, para que los archivos que llegan después tengan un sitio previsible.
03

Delete a directory

files.deleteDirectory

Lo 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.
Casos de uso
una pasada de mantenimiento que retira las carpetas de trabajo del trimestre anterior cuando los datos ya están archivados en otro sitio.
04

Delete a file

files.deleteFile

Lo 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.
Casos de uso
retirar un CSV en bruto cuando la carga ha terminado, para que en el volumen solo quede el resultado procesado.
05

Download a file

files.downloadFile

Lo 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.
Casos de uso
sacar el informe en PDF generado de madrugada para enviarlo adjunto al equipo financiero.
06

Get file info

files.getFileInfo

Lo 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.
Casos de uso
un paso de control que confirma que la exportación nocturna llegó antes de que el resto del flujo empiece a procesarla.
07

List a directory

files.listDirectory

Lo 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.
Casos de uso
revisar cada mañana la carpeta de entrada y procesar todo lo que se dejó ahí durante la noche.
08

Upload a file

files.uploadFile

Lo 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.
Casos de uso
dejar en un volumen la hoja de cálculo que manda un proveedor para que un proceso programado la ingiera.

Genie

6 operaciones
09

Create a conversation message

genie.createMessage

Lo 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.
Casos de uso
un asistente que traslada cada pregunta nueva de un canal al mismo hilo de Genie.
10

Execute a message SQL query

genie.executeMessageQuery

Lo 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.
Casos de uso
convertir la pregunta de una analista en una consulta realmente ejecutada, sin que nadie escriba el SQL a mano.
11

Get a conversation message

genie.getMessage

Lo 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 }}.
Casos de uso
un bucle de espera que solo reenvía la respuesta al equipo cuando Genie la ha terminado.
12

Get a Genie space

genie.getSpace

Lo 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.
Casos de uso
un flujo de preparación que lee una vez los detalles del espacio y los deja guardados, para que el equipo elija luego un espacio por su nombre en lugar de pegar un identificador en cada nodo.
13

Get query results

genie.getQueryResults

Lo 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.
Casos de uso
volcar en una hoja las cifras que hay detrás de una respuesta de Genie, para que el equipo reciba la tabla y no solo la frase.
14

Start a conversation

genie.startConversation

Lo 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 }}.
Casos de uso
un formulario interno que abre una conversación por solicitud, de forma que cada persona mantiene sus repreguntas aparte.

Model Serving

1 operación
15

Query a serving endpoint

modelServing.queryEndpoint

Lo 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.
Casos de uso
puntuar cada solicitud entrante y derivar las mejores a una persona de ventas.

Unity Catalog

17 operaciones
16

Create a catalog

unityCatalog.createCatalog

Lo 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 description como texto de ejemplo en el campo. Se agradece cuando varios equipos comparten el mismo workspace.
Casos de uso
una empresa de logística que abre un catálogo por país de operación desde un flujo, en lugar de hacerlo a mano en la interfaz de Databricks.
17

Create a function

unityCatalog.createFunction

Lo 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_name y type_text.
  • Return Type: el tipo que devuelve, por ejemplo STRING, INT o DOUBLE.
  • 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.
Casos de uso
una inmobiliaria que publica una vez su fórmula de rentabilidad, en vez de verla copiada en cada consulta.
18

Create a table

unityCatalog.createTable

Lo 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_name entre STRING, LONG, DOUBLE, BOOLEAN, DATE o TIMESTAMP.
Casos de uso
una exportación nocturna que aterriza en el almacenamiento de objetos y queda registrada como tabla en cuanto llega el fichero.
19

Create a volume

unityCatalog.createVolume

Lo 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; con EXTERNAL, 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.
Casos de uso
un volumen por hotel para las facturas escaneadas de proveedores, creado el día que ese hotel entra en el grupo.
20

Delete a catalog

unityCatalog.deleteCatalog

Lo 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.
Casos de uso
desmontar el catálogo de pruebas que se montó para una formación interna, una vez terminada la sesión.
21

Delete a function

unityCatalog.deleteFunction

Lo 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.
Casos de uso
un flujo de despliegue que borra la versión anterior de una función auxiliar y registra la nueva en la misma ejecución.
22

Delete a table

unityCatalog.deleteTable

Lo 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.
Casos de uso
limpieza lanzada por un Schedule Trigger, que vacía las tablas de preparación que dejó una carga interrumpida.
23

Delete a volume

unityCatalog.deleteVolume

Lo 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.
Casos de uso
el cierre de una cuenta, con el volumen que guardaba sus ficheros retirado como último paso de la baja.
24

Get a catalog

unityCatalog.getCatalog

Lo 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.
Casos de uso
un paso de guardia al principio de un proceso nocturno, que comprueba el catálogo de destino antes de lanzar las cargas.
25

Get a function

unityCatalog.getFunction

Lo 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.
Casos de uso
documentar lo que expone un esquema financiero, con un item por función enviado a una hoja de cálculo al cerrar la ejecución.
26

Get a table

unityCatalog.getTable

Lo 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.
Casos de uso
una auditoría que recorre un esquema y anota lo que declara cada tabla, con una expresión genérica como {{ $json.field }} alimentando el nodo siguiente.
27

Get a volume

unityCatalog.getVolume

Lo 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.
Casos de uso
un flujo de ingesta de archivos que confirma que el volumen de destino está creado antes de mover el primer fichero.
28

List catalogs

unityCatalog.listCatalogs

Lo 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.

Casos de uso
un inventario semanal que lista los catálogos, itera sobre ellos y deja el resultado en una hoja compartida con quien lleva el gobierno del dato.
29

List functions

unityCatalog.listFunctions

Lo 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.
Casos de uso
preparar un comité de datos, llevando la lista de funciones del esquema analítico a un mensaje de Slack esa misma mañana.
30

List tables

unityCatalog.listTables

Lo 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.
Casos de uso
una página de inventario para el equipo de datos, reconstruida a intervalos regulares para que las tablas nuevas aparezcan sin que nadie edite un documento.
31

List volumes

unityCatalog.listVolumes

Lo 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.
Casos de uso
una revisión trimestral que lista los volúmenes de cada esquema y manda el resultado por correo a la persona responsable de ese esquema.
32

Update a catalog

unityCatalog.updateCatalog

Lo 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 description como texto de ejemplo. Es la parte que los equipos mantienen de verdad al día.
Casos de uso
un flujo lanzado desde una herramienta de tickets que reescribe la descripción del catálogo cada vez que cambia el equipo propietario.

Vector Search

4 operaciones
33

Create a vector search index

vectorSearch.createIndex

Lo 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 ID como ejemplo en el campo.
  • Index Type: DELTA_SYNC se sincroniza automáticamente con una tabla Delta de origen, DIRECT_ACCESS admite 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.
Casos de uso
levantar el índice que hay detrás de un asistente interno de ayuda, desde el mismo flujo que prepara su tabla de origen.
34

Get a vector search index

vectorSearch.getIndex

Lo 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 }}.
Casos de uso
un control colocado delante del paso de recuperación, para que un asistente de soporte no consulte nunca un índice que no está.
35

List vector search indexes

vectorSearch.listIndexes

Lo 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.
Casos de uso
una vigilancia matinal que lista lo que corre en el endpoint de producción y publica el resultado en un canal del equipo.
36

Query a vector search index

vectorSearch.queryIndex

Lo 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; con vector, 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: HYBRID combina búsqueda semántica y por palabras clave, ANN se queda en similitud vectorial pura.
  • Score Threshold, dentro de Options: la puntuación mínima de relevancia, entre 0 y 1.
Casos de uso
traer los pasajes de documentación más cercanos a la pregunta de un cliente antes de que un paso de IA redacte la respuesta.
Necesitas ayuda

¿Necesitas ayuda para automatizar Databricks con n8n?

El equipo te responde directamente.

Cada mensaje lo lee una persona.

FAQ

Databricks y n8n, lo que se pregunta después

01¿La integración Databricks n8n es gratuita?
Por el lado de n8n, sí. El nodo Databricks viene incluido con n8n: no hay nada que instalar ni ningún coste añadido por usarlo, tanto en n8n Cloud como en una instancia autoalojada de la Community Edition con licencia Sustainable Use. Un flujo se comporta igual en los dos sitios. El credential sigue la misma lógica: lo creas una vez en el menú Credentials y cualquier flujo que toque el espacio de trabajo lo elige de un desplegable. Lo que cuesta tu propio espacio de Databricks depende de tu contrato, y eso se mira en Databricks, no aquí.
02¿Qué credenciales y qué permisos hacen falta?
El nodo admite un token de acceso personal o OAuth2. El token va ligado a un usuario de Databricks y se combina con un Host, la URL de tu espacio de trabajo, y con el valor del token, que empieza por dapi. OAuth2 llega en dos formas: inicio de sesión en el navegador, donde las operaciones corren con tus permisos y aparecen en los registros de auditoría con tu identidad, o service principal con client ID y secreto para ejecuciones sin nadie delante. A eso se suman los privilegios: el entitlement Workspace access para todo, Databricks SQL access y CAN USE sobre el warehouse para Execute Query, CAN RUN en un espacio de Genie y CAN QUERY en un endpoint de serving.
03¿Qué límites tiene el nodo Databricks?
El nodo abarca 36 operaciones repartidas en 6 recursos. Lo que queda fuera de esas operaciones se resuelve con el nodo HTTP Request, que llama a cualquier endpoint de la API de Databricks reutilizando el mismo credential mediante la autenticación predefinida, así que no gestionas un segundo secreto. Listar un directorio de un volumen está paginado, es decir, troceado en páginas sucesivas: Page Size fija cuántos archivos vuelven de golpe y Page Token trae la página siguiente, algo que importa en cuanto un volumen guarda más archivos de los que devuelve una llamada. La subida también tiene tope, de 5 GiB por archivo.
04¿Puede un flujo reaccionar a algo que pasa en Databricks?
Desde Databricks no. En n8n no existe un nodo trigger de Databricks, entendiendo por trigger el nodo que pone en marcha un flujo. El arranque viene de otro lado y hay tres opciones que cubren casi todo. El Schedule Trigger ejecuta el flujo cada cierto intervalo fijo, que encaja con consultas nocturnas y resúmenes de la mañana. El Webhook de n8n, o sea una URL que n8n publica y a la que llama un servicio externo, arranca la ejecución en cuanto ese servicio tiene algo que decir. Y el trigger de otra herramienta del mismo flujo, una fila nueva o un mensaje nuevo, abre la marcha y el nodo Databricks se ejecuta detrás.
05¿n8n o Make para Databricks?
La decisión se juega en dónde corre la plataforma y cómo se factura. Make está alojada por Make, sin opción de autoalojamiento, y cobra por operación: un flujo que recorre un conjunto grande de resultados sale más caro según crece. n8n funciona en n8n Cloud o en tu propia infraestructura con Docker o npm, y el flujo es idéntico en ambos casos. Con Databricks pesa bastante, porque el resultado de una consulta suele ser justo el dato que un equipo prefiere mantener dentro de su red. Si trabajas en visual y no quieres pensar en servidores, Make es el camino más ligero.
Hack'celeration Lab

Recibe nuestros tips de integración cada semana.

Sin spam. Cancela cuando quieras.