Discover and reattach to Microsoft Fabric Livy work

Lists existing Livy sessions or batches and creates a newly authenticated handle for work that was started by an earlier R process. Listing never returns authentication credentials. Attaching retrieves current service state and does not create a new session or batch.

Usage

fabric_livy_sessions(
  livy_url,
  high_concurrency = FALSE,
  top = 100L,
  skip = 0L,
  count = TRUE,
  tenant_id = Sys.getenv("FABRICQUERYR_TENANT_ID"),
  client_id = Sys.getenv("FABRICQUERYR_CLIENT_ID", unset =
    "04b07795-8ddb-461a-bbee-02f9e1bf7b46"),
  token = NULL,
  auth_args = list(),
  audience = NULL
)

fabric_livy_batches(
  livy_url,
  top = 100L,
  skip = 0L,
  count = TRUE,
  tenant_id = Sys.getenv("FABRICQUERYR_TENANT_ID"),
  client_id = Sys.getenv("FABRICQUERYR_CLIENT_ID", unset =
    "04b07795-8ddb-461a-bbee-02f9e1bf7b46"),
  token = NULL,
  auth_args = list(),
  audience = NULL
)

fabric_livy_session_attach(
  livy_url,
  session_id,
  high_concurrency = FALSE,
  tenant_id = Sys.getenv("FABRICQUERYR_TENANT_ID"),
  client_id = Sys.getenv("FABRICQUERYR_CLIENT_ID", unset =
    "04b07795-8ddb-461a-bbee-02f9e1bf7b46"),
  token = NULL,
  auth_args = list(),
  audience = NULL,
  verbose = TRUE
)

fabric_livy_batch_attach(
  livy_url,
  batch_id,
  tenant_id = Sys.getenv("FABRICQUERYR_TENANT_ID"),
  client_id = Sys.getenv("FABRICQUERYR_CLIENT_ID", unset =
    "04b07795-8ddb-461a-bbee-02f9e1bf7b46"),
  token = NULL,
  auth_args = list(),
  audience = NULL,
  verbose = TRUE
)

Arguments

livy_url

A copied session or batch connection URL, Livy API base URL, or enriched Lakehouse object from fabric_lakehouses() or fabric_item()

high_concurrency

For fabric_livy_session_attach(), whether to attach to a high-concurrency session. fabric_livy_sessions() only lists regular sessions because the Livy endpoint does not expose a high-concurrency collection-list operation

top

Maximum records requested for this page

skip

Number of matching records to skip

count

Whether Fabric should include the total matching record count

tenant_id

Microsoft Entra tenant ID. Defaults to FABRICQUERYR_TENANT_ID

client_id

Microsoft Entra application/client ID. Defaults to FABRICQUERYR_CLIENT_ID, then the Azure CLI application ID

token

Optional access token or token-provider function. Leave NULL to use the normal sign-in flow for a Microsoft Fabric host. A custom livy_url requires an explicitly supplied token or provider

auth_args

Additional sign-in options passed to AzureAuth::get_azure_token()

audience

Optional sign-in scopes. Delegated sign-in defaults to the required Fabric Livy scopes; client credentials require one .default audience

session_id, batch_id

Service GUID returned by a list or submit operation

verbose

Logical. Show handle lifecycle messages

Value

fabric_livy_sessions() and fabric_livy_batches() return one page as a tibble with columns id, name, state, result, app_id, service timestamps, and raw. The tibble has total_count, page_size, and skip attributes. The attach functions return a FabricLivySession or FabricLivyBatch with a fresh in-process credential.

Restart recovery

Livy handles intentionally do not serialize their credentials. Store the service ID, then call the corresponding attach function after restarting R. Attaching only reconstructs the local handle; it never submits new Spark work.

High-concurrency recovery

Fabric supports acquiring an HC session and getting or deleting one by its HC session ID, but it does not expose a collection GET for highConcurrencySessions. Store the ID returned by fabric_livy_session() and pass it to fabric_livy_session_attach() with high_concurrency = TRUE. Calling fabric_livy_sessions() with high_concurrency = TRUE fails locally instead of sending an unsupported request.

See also

Microsoft Fabric Livy API specification and Microsoft's high-concurrency endpoint reference

Examples

if (FALSE) { # \dontrun{
workspace <- fabric_workspaces()[[1L]]
lakehouse <- fabric_lakehouses(workspace)[[1L]]

sessions <- fabric_livy_sessions(lakehouse)
session <- fabric_livy_session_attach(lakehouse, sessions$id[[1L]])
session$status()

batches <- fabric_livy_batches(lakehouse)
batch <- fabric_livy_batch_attach(lakehouse, batches$id[[1L]])
batch$status()
} # }