realtime-cinema-data-engineering-pipeline: скилл для Claude Code
Набор инструкций для развёртывания потоковой обработки транзакций кинотеатра на стеке из брокера сообщений, базы данных и планировщика задач.
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-codeЧто делает realtime-cinema-data-engineering-pipeline
Скилл инструктирует ассистента по сборке потокового конвейера на базе Apache Kafka, PostgreSQL и Apache Airflow. Входящие события продаж билетов генерируются скриптом через Faker, поступают в топик брокера и сохраняются консьюмером в сырую JSON-таблицу.
Хранилище строится по медальонной структуре. Сырой слой Bronze принимает неструктурированные события, слой Silver нормализует записи в реляционные таблицы третьей нормальной формы, а Gold формирует материализованные представления для витрин аналитики и дашборда на Streamlit.
Для запуска окружения требуются Docker Compose и Python 3.8+. Без двух-трёх минут ожидания после команды запуска контейнеров Airflow не успеет инициализироваться, из-за чего запуск пайплайна выдаст ошибку.
Какие задачи решает
- настроить приём потоковых транзакций через Kafka в PostgreSQL
- разделить хранилище на слои Bronze, Silver и Gold
- собрать генератор тестовых событий на Python с библиотекой Faker
- запустить оркестрацию слоёв трансформации через Apache Airflow
Примеры запросов агенту
- Разверни потоковый конвейер с Kafka и Airflow для данных кинотеатра
- Покажи структуру таблиц Bronze, Silver и Gold в PostgreSQL для транзакций
- Напиши скрипт продюсера Kafka для генерации тестовых продаж билетов
Как установить realtime-cinema-data-engineering-pipeline
1Через Skills CLI (Vercel)
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-code2Вручную: положить файлы
~/.claude/skills/realtime-cinema-data-engineering-pipeline/SKILL.mdПапка скилла целиком; для одного проекта — .claude/skills/realtime-cinema-data-engineering-pipeline/
1Через Skills CLI (Vercel)
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a codex2Вручную: положить файлы
.agents/skills/realtime-cinema-data-engineering-pipeline/SKILL.mdДля всех проектов — ~/.agents/skills/
1Через Skills CLI (Vercel)
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a cursor2Вручную: положить файлы
.cursor/skills/realtime-cinema-data-engineering-pipeline/SKILL.mdCursor читает и .agents/skills/, и .claude/skills/
1GitHub CLI
gh skill install reason-machines/data-skills realtime-cinema-data-engineering-pipeline2Вручную: положить файлы
.github/skills/realtime-cinema-data-engineering-pipeline/SKILL.md1Через Skills CLI (Vercel)
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a gemini-cli2Командой платформы
gemini skills install https://github.com/reason-machines/data-skills --path skills/realtime-cinema-data-engineering-pipelineВручную: положить файлы
.devin/skills/realtime-cinema-data-engineering-pipeline/SKILL.mdСтарый путь .windsurf/skills/ тоже читается
Через Skills CLI (Vercel)
npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a opencodeClaude.ai
Упакуйте папку в zip и загрузите в Settings → Capabilities → Skills
По шагам, с командами для каждой платформы: Как установить скилл в Claude Code: пять способов
Вопросы о realtime-cinema-data-engineering-pipeline
Как установить realtime-cinema-data-engineering-pipeline в Claude Code?
Выполните команду npx skills add reason-machines/data-skills --skill realtime-cinema-data-engineering-pipeline -a claude-code. Агент подключит инструкции к рабочей сессии.
Что делает realtime-cinema-data-engineering-pipeline?
Скилл даёт ассистенту шаблоны кода и схему данных для сквозной обработки событий кинотеатра от генерации в Kafka до витрин в PostgreSQL.
Что нужно подготовить перед запуском проекта?
Потребуются установленные Docker, Docker Compose и Python версии не ниже 3.8. После подъёма контейнеров нужно подождать 2–3 минуты для старта Airflow.
