databricks-zerobus-ingest

Ingest data into Unity Catalog Delta tables via Zerobus Ingest over gRPC.

Updated Sep 9, 2017
One-click install
npx skills add https://github.com/mirakui/dotfiles --skill databricks-zerobus-ingest-mirakui
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-zerobus-ingest
Source: https://github.com/mirakui/dotfiles/tree/main/claude/skills/databricks-zerobus-ingest
Command: npx skills add https://github.com/mirakui/dotfiles --skill databricks-zerobus-ingest-mirakui

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Zerobus Ingest enables direct, serverless data ingestion into Databricks Delta tables via gRPC, removing the need for message buses and enabling real-time producers.

Core Features & Use Cases

  • Cross-language SDKs (Python, Java, Go, TypeScript, Rust) for streaming ingestion
  • Protobuf schema generation from Unity Catalog tables and 1:1 field mapping
  • Robust ACK handling and retry/reconnection patterns for at-least-once delivery
  • No automatic table management; pre-create your Delta table and manage schema evolution

Quick Start

Run a minimal Python JSON flow to create a Zerobus stream and ingest a sample record into a Delta 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 directly into Databricks Delta tables via gRPC?

You can ingest data directly into Delta tables via gRPC using Zerobus Ingest. This serverless approach removes the need for message buses by streaming records straight into Unity Catalog.

What is the best way to generate Protobuf schemas from Unity Catalog tables for stream ingestion?

Generating Protobuf schemas from Unity Catalog tables enables 1:1 field mapping for Zerobus ingestion. This Skill guides software engineers through schema generation to implement stream-based ingestion with ACK handling.

Can I use Zerobus to ingest Delta data with Python, Java, Go, TypeScript, and Rust SDKs?

Yes, Zerobus Ingest supports cross-language SDKs for Python, Java, Go, TypeScript, and Rust. These SDKs allow data engineers to build streaming producers that implement record ingestion, ACK waiting, and error handling.

Do I need to pre-create Delta tables for Zerobus stream ingestion?

Yes, you must pre-create your Delta table in Unity Catalog before using Zerobus. The system provides no automatic table management, meaning data engineers are responsible for managing schema evolution themselves.

How does Zerobus handle delivery guarantees and connection failures during Delta ingestion?

Zerobus handles Delta ingestion delivery guarantees using ACK handling and retry/reconnection patterns. This approach ensures at-least-once delivery by managing stream creation, callbacks, flushing, and error handling.