Skip to main content
affpapa.org
RU EN
skill CX Codex

realtime-cinema-data-engineering-pipeline: Claude Code skill

Instructions for assembling a streaming pipeline that routes simulated ticket transactions through message queues and warehouse layers.

Install into Claude Code · Skills CLI (Vercel) All methods and platforms ↓ 
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-code
Open on GitHub

What realtime-cinema-data-engineering-pipeline does

This skill guides your coding assistant through setting up event streaming for cinema box office records. Synthetic ticket purchases generated via Faker land in an Apache Kafka topic, while a background consumer loads raw payloads directly into PostgreSQL.

Data organization follows a tiered setup. The bronze tier keeps raw JSON payloads, the silver tier breaks details into normalized third-normal-form relational tables, and the gold tier prepares materialized aggregates for Streamlit reports. Airflow schedules and runs the downstream transformations.

Running this setup requires Python 3.8+ alongside Docker Compose. Without waiting two or three minutes after starting the containers, Airflow will not finish its boot process and scheduled tasks will fail.

What it helps with

  • ingest continuous event streams from Kafka into PostgreSQL
  • structure database storage into bronze, silver, and gold tiers
  • mock ticket purchasing events using Python and Faker
  • orchestrate relational transformations with Apache Airflow

Example prompts for the agent

  • Set up a streaming event pipeline using Kafka, PostgreSQL, and Airflow
  • Show me how to split cinema event payloads into normalized silver tables
  • Generate synthetic movie ticket sales with a Kafka producer script

How to install realtime-cinema-data-engineering-pipeline

1Skills CLI (Vercel)

npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-code

2Manually: put the files in place

~/.claude/skills/realtime-cinema-data-engineering-pipeline/SKILL.md

Copy the whole skill folder; for one project use .claude/skills/realtime-cinema-data-engineering-pipeline/

Step by step, with commands for each platform: How to install skills in Claude Code: five ways

Questions about realtime-cinema-data-engineering-pipeline

How to install realtime-cinema-data-engineering-pipeline in Claude Code?

Run npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-code. This links the skill configurations directly to your agent.

What does realtime-cinema-data-engineering-pipeline do?

It supplies reference code, database schemas, and orchestration setups for processing live event streams through message brokers and analytical database layers.

What system dependencies are required?

You need Python 3.8 or newer, Docker, and Docker Compose installed locally. Airflow containers also require two to three minutes to initialize before accepting workloads.

Similar skills

All skills for Data and databases →
neon-realtime neondatabase Turns any SQL query live: the client subscribes to row changes in Lakebase Postgres and gets them in batches. Useful for dashboards, feeds and multi-device sync. CX Codex +1 6,000installs postgresql-database-engineering manutej Guides database design, index selection, and query optimization in PostgreSQL. Useful when tuning slow queries, setting up table partitioning, or configuring replication. CX Codex +1 1,800installs turbo-builder goldsky-io Walks you from a data goal to a deployed Goldsky Turbo YAML pipeline: dataset choice, sources, transforms and sinks. CX Codex +1 3,600installs digitalocean-managed-databases bobmatnyc Provides database provisioning, scaling, and network security patterns for DigitalOcean. Useful when managing PostgreSQL, Redis, Kafka, or MySQL clusters. CX Codex +1 393installs typescript-e2e-testing bmad-labs Guides Claude Code and other tools through setting up, writing, and debugging E2E tests for TypeScript and NestJS using Jest, Supertest, and Docker. CX Codex +1 2,300installs data-engineer Seth Hobson A subagent for data pipelines, warehouses, and streaming architectures. Use it for Apache Spark, dbt, Airflow, and cloud data platform work. CX Codex 3,194installs

From the same set62

harvard-artifacts-data-engineering-pipeline Pulls artifact records from the Harvard Art Museums API, loads them into SQL tables, and renders a Streamlit dashboard on top. CX Codex +1 2,000installs harvard-art-museum-etl-analytics Sets up an ETL workflow for the Harvard Art Museums API, organizes museum items into MySQL tables, and renders Streamlit visualizations. CX Codex +1 2,000installs harvard-art-museums-etl-analytics This skill pulls Harvard Art Museums records through the API, stores structured data in SQL, and supports Streamlit dashboards for collection analysis. CX Codex +1 2,000installs harvard-artifacts-etl-analytics A skill that walks your agent through building an ETL pipeline and an analytics dashboard on Harvard Art Museums API data. Useful when you want a set route from API calls to Streamlit charts. CX Codex +1 2,000installs harvard-art-museums-data-pipeline Builds a museum-artifact data flow from the Harvard API to SQL analysis and a Streamlit dashboard. Useful for collection data projects. CX Codex +1 2,000installs amee-joshi-data-engineering-portfolio A reference skill with Azure data engineering examples: Bronze–Silver–Gold layers, Delta Lake, dimensional models and pipeline designs. CX Codex +1 2,000installs enterprise-data-engineering-pipeline-ssis-pyspark Guides coding assistants through building an ELT pipeline with SQL Server star schemas, SSIS orchestration packages, and PySpark analytics jobs. CX Codex +1 2,000installs data-engineering-study-material A study guide skill for data engineering: explains concepts, shows pipeline examples, and helps with interview prep. CX Codex +1 2,000installs

Project sponsors

Companies that keep this analytics open
Gold sponsor
Nutra.Club

Impressions, clicks and code copies — open statistics. We keep the numbers public for the same reason NeBlask itself is public. Become a sponsor