Skip to main content
Version: 2.6.0

Microsoft Fabric (OneLake) Nodes

Microsoft Fabric OneLake nodes let pipelines read and write files in a Fabric lakehouse over the ADLS Gen2 endpoint. Use them to land OT payloads and Parquet inputs, list and create directories, and clean up processed files. All five node types connect through your configured Microsoft Fabric (OneLake) connections.

Configuration Quick Reference

FieldWhat you chooseDetails
ParametersConnection, Function, Function Parameters, Timeout OverrideSelect the connection profile, function, configure function parameters with expression support, and optionally override timeout.
SettingsDescription, Timeout (seconds), Retry on Timeout, Retry on Fail, On ErrorNode description, maximum execution time, retry behavior on timeout or failure, and error handling strategy. All execution settings default to pipeline-level values.

Path Operations

OneLake Write File Node

OneLake Write File node configuration

OneLake Write File Node

Upload data to a file under the configured workspace and lakehouse, creating it or overwriting an existing file.

Supported Function Types:

Function NamePurposeCommon Use Cases
Write FileUpload data to a lakehouse file pathLanding OT snapshots, writing Parquet for Direct Lake, archiving pipeline output

Node Configuration

ParameterTypeRequiredDescription
ConnectionSelectionYesMicrosoft Fabric (OneLake) connection profile to use
FunctionSelectionYesWrite function from the selected connection
Function ParametersDynamicVariesAuto-populated from the function schema (e.g. path, data). See your OneLake connection functions for full parameter details.
Timeout OverrideNumber (seconds)NoOverride the default function timeout

All function parameters support expression syntax ({{ expression }}) for dynamic values from the pipeline context.

Output Structure

{
"success": true,
"functionId": "<function-id>",
"data": {
"path": "Files/snapshots/2026-06-03.json",
"bytesWritten": 2048,
"contentType": "application/json"
}
}
FieldTypeDescription
pathstringResolved lakehouse path the file was written to
bytesWrittennumberNumber of bytes written
contentTypestringMIME content type applied (auto-detected when not supplied)
Store-and-forward eligible

The Write File node is a durable sink with keyed idempotency — the path is the idempotency handle, so retries converge to the same end state.


OneLake Read File Node

OneLake Read File node configuration

OneLake Read File Node

Download the full content of a file from the lakehouse and return it as node output.

Supported Function Types:

Function NamePurposeCommon Use Cases
Read FileDownload a lakehouse file's contentReading reference files, configuration blobs, archived payloads

Node Configuration

ParameterTypeRequiredDescription
ConnectionSelectionYesMicrosoft Fabric (OneLake) connection profile to use
FunctionSelectionYesRead function from the selected connection
Function ParametersDynamicVariesAuto-populated from the function schema (e.g. path). See your OneLake connection functions for full parameter details.
Timeout OverrideNumber (seconds)NoOverride the default function timeout

Output Structure

{
"success": true,
"functionId": "<function-id>",
"data": {
"data": "id,value\n1,42\n",
"metadata": {
"path": "Files/reference/lookup.csv",
"fileName": "lookup.csv",
"sizeBytes": 15,
"encoding": "text"
}
}
}
FieldTypeDescription
datastringFile content — text, or base64 for binary content types
metadata.pathstringResolved lakehouse path read
metadata.fileNamestringFile name extracted from the path
metadata.sizeBytesnumberFile size in bytes
metadata.encodingstringtext or base64 — how data is encoded

OneLake List Paths Node

OneLake List Paths node configuration

OneLake List Paths Node

Enumerate paths under a directory, optionally recursively, with pagination.

Supported Function Types:

Function NamePurposeCommon Use Cases
List PathsEnumerate files and directories under a pathDiscovering files, building inventories, driving fan-out

Node Configuration

ParameterTypeRequiredDescription
ConnectionSelectionYesMicrosoft Fabric (OneLake) connection profile to use
FunctionSelectionYesList function from the selected connection
Function ParametersDynamicVariesAuto-populated from the function schema (e.g. path, recursive, maxResults). See your OneLake connection functions for full parameter details.
Timeout OverrideNumber (seconds)NoOverride the default function timeout

Output Structure

{
"success": true,
"functionId": "<function-id>",
"data": {
"path": "Tables/sensor_readings",
"paths": [
{
"name": "Tables/sensor_readings/data.parquet",
"isDirectory": false,
"contentLength": 20480,
"lastModified": "Tue, 03 Jun 2026 08:00:00 GMT",
"etag": "0x8D..."
}
],
"count": 1,
"continuationToken": "..."
}
}
FieldTypeDescription
pathstringDirectory that was listed
pathsarrayPath entries (see below)
countnumberNumber of entries returned
continuationTokenstringPresent only when more pages remain

Path Entry Fields:

FieldTypeDescription
namestringFull path of the entry
isDirectorybooleantrue if the entry is a directory
contentLengthnumberSize in bytes (files)
lastModifiedstringLast modification timestamp
etagstringEntry ETag

OneLake Create Directory Node

OneLake Create Directory node configuration

OneLake Create Directory Node

Create a directory in the lakehouse. Idempotent — succeeds if it already exists.

Supported Function Types:

Function NamePurposeCommon Use Cases
Create DirectoryCreate a lakehouse directoryLaying out partitioned paths, pre-provisioning folders

Node Configuration

ParameterTypeRequiredDescription
ConnectionSelectionYesMicrosoft Fabric (OneLake) connection profile to use
FunctionSelectionYesCreate Directory function from the selected connection
Function ParametersDynamicVariesAuto-populated from the function schema (e.g. path). See your OneLake connection functions for full parameter details.
Timeout OverrideNumber (seconds)NoOverride the default function timeout

Output Structure

{
"success": true,
"functionId": "<function-id>",
"data": {
"path": "Files/daily/2026-06-03",
"created": true
}
}
FieldTypeDescription
pathstringResolved directory path
createdbooleantrue on success (also when the directory already existed)

OneLake Delete Path Node

OneLake Delete Path node configuration

OneLake Delete Path Node

Permanently remove a file or directory from the lakehouse, optionally recursively.

Supported Function Types:

Function NamePurposeCommon Use Cases
Delete PathDelete a file or directoryRetention cleanup, undo-on-failure, removing processed inputs

Node Configuration

ParameterTypeRequiredDescription
ConnectionSelectionYesMicrosoft Fabric (OneLake) connection profile to use
FunctionSelectionYesDelete function from the selected connection
Function ParametersDynamicVariesAuto-populated from the function schema (e.g. path, recursive). See your OneLake connection functions for full parameter details.
Timeout OverrideNumber (seconds)NoOverride the default function timeout

Output Structure

{
"success": true,
"functionId": "<function-id>",
"data": {
"path": "Files/staging/processed.json",
"kind": "file",
"deleted": true
}
}
FieldTypeDescription
pathstringResolved path that was deleted
kindstringfile or directory
deletedbooleantrue if the path was deleted
Destructive Operation

Deletion is permanent and cannot be undone. Enable Recursive only when you intend to remove a directory and all of its contents; use a Condition node to verify before deleting.


Settings Tab

All Microsoft Fabric (OneLake) node types share the same Settings tab:

SettingTypeDefaultDescription
DescriptionTextOptional description displayed on the node
Timeout (seconds)NumberPipeline defaultMaximum time the node may run before timing out
Retry on TimeoutTogglePipeline defaultAutomatically retry the node if it times out
Retry on FailTogglePipeline defaultAutomatically retry the node if it fails
On ErrorSelectionPipeline defaultError strategy: stop the pipeline, continue to the next node, or follow the error output path

When left at their defaults, these settings inherit from the pipeline-level execution configuration.