databricks-zerobus-ingest

Ingest data into Databricks Delta tables via the Zerobus gRPC API.

Updated Jun 11, 2026
One-click install
npx skills add https://github.com/Zack2626-ok/DATN_Website-Dat-Ban-Va-Quan-Ly-Nha-Hang --skill databricks-zerobus-ingest-zack2626-ok
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-zerobus-ingest
Source: https://github.com/Zack2626-ok/DATN_Website-Dat-Ban-Va-Quan-Ly-Nha-Hang/tree/main/.windsurf/skills/databricks-zerobus-ingest
Command: npx skills add https://github.com/Zack2626-ok/DATN_Website-Dat-Ban-Va-Quan-Ly-Nha-Hang --skill databricks-zerobus-ingest-zack2626-ok

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill requires databricks-sdk, databricks-zerobus-ingest-sdk, grpcio-tools, and includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill solves the challenge of ingesting data into Databricks Delta tables with near real-time precision, without the need for message bus infrastructure.

Core Features & Use Cases

  • Direct Ingestion: Writes data directly into Delta tables, reducing latency and infrastructure complexity.
  • Schema Evolution: Manages schema changes by regenerating Protobuf schemas and recompiling language bindings.
  • Retry Logic: Handles connection issues and server maintenance gracefully with retry and reconnection patterns.
  • Use Case: Ideal for high-throughput data ingestion from various sources, such as IoT devices, web applications, and batch processing jobs.

Quick Start

Use the databricks-zerobus-ingest skill to create a client and ingest records into your Delta table 'my_catalog.my_schema.my_table'.

Frequently Asked Questions about databricks-zerobus-ingest

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

FAQPage Schema
How do I ingest data into Databricks Delta tables without using a message bus?

You can ingest data into Databricks Delta tables without a message bus by using the Zerobus gRPC API. This approach writes records directly to Delta tables, reducing latency and eliminating infrastructure complexity.

What serialization formats does the Zerobus gRPC API support for Databricks data ingestion?

The Zerobus gRPC API supports JSON and Protobuf serialization for Databricks data ingestion. Schema evolution is managed by regenerating Protobuf schemas and recompiling language bindings as needed.

Can I use this direct ingestion method for high-throughput IoT data in Databricks?

Yes, this direct ingestion method is suitable for high-throughput data from IoT devices, web applications, and batch processing jobs. It provides near real-time precision and handles high volumes efficiently.

Do I need Unity Catalog access to ingest data into Delta tables with Zerobus?

Yes, Unity Catalog access is required to ingest data into Delta tables with Zerobus. You also need the Zerobus Ingest SDK and databricks-sdk dependencies to establish the client connection.

How does real-time data ingestion handle connection issues and server maintenance?

Real-time data ingestion handles connection issues and server maintenance through built-in retry and reconnection patterns. It ensures at-least-once delivery and provides durability acknowledgments for ingested records.

What is the best way to manage schema evolution when ingesting data into Databricks Delta tables?

The best way to manage schema evolution during Databricks data ingestion is by regenerating Protobuf schemas and recompiling language bindings. This ensures your Delta tables adapt to changing data structures.