Senior Data Engineer
<p></p> <p>Our client is looking for a Senior Data Engineer to design, scale, and maintain high-performance ingestion, Change Data Capture (CDC), and delivery pipelines. In this role, you will architect enterprise-grade data platforms to process large-scale metadata, algorithmic feature extraction, and licensable asset datasets.</p> <p>This team sits at the foundation of the data processing and feature enrichment pipelines. Driving consistency and performance across an ever-growing data lake, we provide guardrails and sound system design patterns to inform the creation and fine-tuning of the industry's cutting-edge foundational large language models.</p> <p>You will leverage Google Cloud Platform (GCP) as the primary compute foundation of a multi-cloud data processing ecosystem, alongside hybrid data warehouses and query engines including Snowflake and ClickHouse to provide low-latency data exposure, incremental delta tracking, and seamless integration endpoints for downstream AI/ML consumption.</p> <p>Primary Tech Stack: GCP, ClickHouse, Snowflake, dbt Core, Apache Airflow, Python, SQL.</p> <p><strong>Responsibilities</strong><br>1. Ingestion Architecture &amp; GCP Foundation:<br>- Architect, build, and optimize scalable job creation, batching, and high-throughput ingestion pipelines hosted on GCP.<br>- Implement serverless and containerized data pipelines using GCP infrastructure (BigQuery, Dataflow, Pub/Sub, Cloud Storage, GKE).<br>2. Enterprise ETL, CDC &amp; Incremental Processing:<br>- Design robust Change Data Capture (CDC) and incremental update workflows to enable fast delta synchronization across platforms.<br>- Build dbt transformation models and Airflow orchestrations following Data Vault / dimensional modeling patterns.<br>- Implement delta tracking methods (e.g., hash keys, hash diffs) to track row-level asset modifications and metadata events.<br>3. Multi-Engine Analytics &amp; Query Optimization:<br>- Maintain and optimize Snowflake integration layers, handling deduplication logic, canonical content filtering, and policy restrictions.<br>- Deploy and manage ClickHouse as a high-concurrency analytical engine to deliver sub-second metadata retrieval and indexing.<br>- Construct dedicated integration views and API query layers allowing internal and external clients to consume real-time delta updates.<br>4. Data Quality, Governance &amp; Scalability:<br>- Enforce metadata schema standardization, canonical asset mapping, and automated validation layers across diverse asset types (images, video, 3D models, audio).<br>- Collaborate closely with cross-functional teams to integrate metadata pipelines with feature extraction tools, search indexes, and licensing platforms.</p> <p><strong>Requirements</strong><br>- Google Cloud Platform (GCP): 4+ years of production experience with core GCP data technologies (BigQuery, Dataflow, Cloud Pub/Sub, GKE, Google Cloud Storage).<br>- Database &amp; Query Engines: Deep technical proficiency with both Snowflake (warehousing, semi-structured queries, integration layers) and ClickHouse (real-time aggregation, low-latency columnar storage, indexing).<br>- Enterprise ETL / CDC: Proven experience architecting CDC pipelines and incremental delta loading for multi-terabyte dataset scale.<br>- Data Transformation &amp; Orchestration: Hands-on mastery of dbt Core/Cloud and Apache Airflow in an enterprise CI/CD setting (e.g., GitHub Actions).<br>- Programming Skills: Advanced skills in Python and SQL; familiarity with Go, Java, or Scala is a strong plus.</p> <p>Nice-to-Have Qualifications:<br>- Experience with Data Vault 2.0 architecture, hash-key generation, and raw/staging/integration layer design.<br>- Background handling AI/ML metadata, computer vision feature vectors, C2PA provenance headers, or semantic search configurations.<br>- Familiarity with media metadata schemas (images, 3D model stems, video derivatives).<br>- Experience with other major cloud providers such as AWS, Azure, or Oracle Cloud.</p> <p>Key Success Metrics (First 90 Days)<br>- GCP Pipeline Optimization: Standardize ingestion batching and pipeline compute infrastructure on GCP.<br>- ClickHouse &amp; Snowflake Integration: Establish streamlined integration views exposing low-latency metadata delta changes.<br>- Automated CDC Workflows: Finalize automated dbt delta transformations with hash tracking across primary warehouse layers.</p> <p><br><br></p> <p></p><div class="content-conclusion"><p><strong>We offer*:</strong></p> <ul> <li>Flexible working format - remote, office-based or flexible</li> <li>A competitive salary and good compensation package</li> <li>Personalized career growth</li> <li>Professional development tools (mentorship program, tech talks and trainings, centers of excellence, and more)</li> <li>Active tech communities with regular knowledge sharing</li> <li>Education reimbursement</li> <li>Memorable anniversary presents</li> <li>Corporate events and team buildings</li> <li>Other location-specific benefits</li> </ul> <p>*not applicable for freelancers</p></div>
PAIGE