spark-authoring-cli

Develops Microsoft Fabric Spark notebooks and data engineering workflows via REST APIs and CLI.

Updated Jul 14, 2026
One-click install
npx skills add https://github.com/9vantage/skills-for-fabric-clone --skill spark-authoring-cli-9vantage
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: spark-authoring-cli
Source: https://github.com/9vantage/skills-for-fabric-clone/tree/main/plugins/fabric-authoring/skills/spark-authoring-cli
Command: npx skills add https://github.com/9vantage/skills-for-fabric-clone --skill spark-authoring-cli-9vantage

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve? Building Spark data engineering solutions in Microsoft Fabric requires juggling REST APIs, notebook cell authoring, lakehouse configuration, and job orchestration, with many pitfalls like duplicate job submissions, wrong token audiences, and malformed notebook payloads. ## Core Features & Use Cases - Notebook Code Authoring: Write PySpark, Scala, SparkR, and SQL code for Fabric Notebook cells with correct lakehouse access, notebookutils usage, and Spark session configuration. - Workspace & Lakehouse Management: Create workspaces, lakehouses with schema support, and notebooks through the Fabric control-plane REST API using az rest. - Materialized Lake View Authoring: Design Spark SQL MLVs with incremental refresh readiness, data quality constraints, and medallion layering patterns. - Use Case: A data engineer asks to build a bronze-to-silver pipeline: the skill provisions the lakehouse, authors the notebook cells with Delta Lake MERGE logic, and reviews an MLV for incremental refresh eligibility. ## Quick Start Ask the assistant to create a Fabric lakehouse and write a PySpark notebook that ingests a public dataset into a bronze Delta table.

Frequently Asked Questions about spark-authoring-cli

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I create a lakehouse in Microsoft Fabric using the REST API?

POST to /v1/workspaces/{workspaceId}/items with type Lakehouse using az rest and the resource https://api.fabric.microsoft.com. Set creationPayload.enableSchemas to true to organize tables into bronze, silver, and gold schemas.

How do I update notebook content in Fabric via the API?

Use getDefinition to retrieve the notebook, decode the base64 payload, modify the ipynb JSON cells, re-encode, and upload with updateDefinition. Each line in a cell source array must end with a newline character to prevent code merging.

What is the difference between Spark SQL and PySpark Materialized Lake Views?

Spark SQL MLVs support incremental refresh when source tables have Change Data Feed enabled, while PySpark MLVs always use full refresh. Use PySpark only when you need UDFs or complex Python logic that SQL cannot express.

Why does my Fabric Livy session creation return HTTP 500?

The request body must be flat JSON with name, driverMemory, driverCores, executorMemory, and executorCores. Wrapping the body in a payload object or sending only a kind field causes the HTTP 500 error.

Which SQL patterns block incremental refresh for Materialized Lake Views?

Window functions, SELECT DISTINCT, RIGHT or FULL OUTER JOIN, ORDER BY, LIMIT, and non-deterministic functions like current_date force full refresh. Rewrite with INNER JOIN, GROUP BY, and deterministic filters, moving ranking logic downstream.

How do I avoid duplicate notebook job runs in Fabric?

Query job instances from the last five minutes before submitting a new run, and monitor an existing job instead of creating a duplicate. After submission, capture the job instance ID immediately and poll status rather than retrying the POST.