clickzetta-oss-ingest-pipeline

Automate object storage ingestion pipelines into Lakehouse with COPY/INSERT and PIPE management.

8|3|Updated Mar 19, 2026
One-click install
npx skills add https://github.com/yunqiqiliang/clickzetta-skills --skill clickzetta-oss-ingest-pipeline
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: clickzetta-oss-ingest-pipeline
Source: https://github.com/yunqiqiliang/clickzetta-skills/tree/main/clickzetta-oss-ingest-pipeline
Command: npx skills add https://github.com/yunqiqiliang/clickzetta-skills --skill clickzetta-oss-ingest-pipeline

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

Object storage data ingestion into Lakehouse is often complex and error-prone without a unified workflow.

Core Features & Use Cases

  • Continuous ingestion: LIST_PURGE and EVENT_NOTIFICATION modes for near real-time loading from OSS/S3/COS.
  • Batch loading: Volume + COPY/INSERT workflows for bulk imports from object storage.
  • Operational governance: Manage Connections, Volumes, and PIPEs with monitoring and load history.

Quick Start

Configure storage connections and volumes, then create a PIPE to start ingesting data from OSS into Lakehouse.

Frequently Asked Questions about clickzetta-oss-ingest-pipeline

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

FAQPage Schema
How do I ingest data from object storage into a lakehouse?

To ingest data from object storage into a lakehouse, you can configure storage connections and external volumes, then create a PIPE to automate the data loading process.

What is the difference between continuous ingestion and batch loading for object storage?

Continuous ingestion uses LIST_PURGE and EVENT_NOTIFICATION modes for near real-time loading, while batch loading utilizes Volume and COPY or INSERT workflows for bulk imports into the lakehouse.

How do I set up continuous object storage ingestion pipelines?

You set up continuous object storage ingestion pipelines by creating a PIPE configured with INGEST_MODE options like LIST_PURGE or EVENT_NOTIFICATION to enable near real-time loading from OSS, S3, or COS.

Can I track load history and manage operational governance for object storage ingestion?

Yes, you can track load history and manage operational governance for object storage ingestion by monitoring active PIPEs, applying purge semantics, and reviewing load history records within the lakehouse environment.

Does object storage ingestion support both OSS and S3 connections?

Yes, object storage ingestion supports connections to OSS, S3, and COS, allowing you to configure external volumes and execute COPY or INSERT workflows to load data into the lakehouse.

When should I use batch loading instead of continuous ingestion for lakehouse pipelines?

You should use batch loading instead of continuous ingestion for lakehouse pipelines when performing bulk imports from object storage using Volume and COPY or INSERT workflows, rather than requiring near real-time event-driven loading.