Data Engineering Podcast
Data Engineering Podcast

Data Engineering Podcast

Tobias Macey

Overview
Episodes

Details

This show goes behind the scenes for the tools, techniques, and difficulties associated with the discipline of data engineering. Databases, workflows, automation, and data manipulation are just some of the topics that you will find here.

Recent Episodes

How Orchestration Impacts Data Platform Architecture
DEC 16, 2024
How Orchestration Impacts Data Platform Architecture
Summary<br />The core task of data engineering is managing the flows of data through an organization. In order to ensure those flows are executing on schedule and without error is the role of the data orchestrator. Which orchestration engine you choose impacts the ways that you architect the rest of your data platform. In this episode Hugo Lu shares his thoughts as the founder of an orchestration company on how to think about data orchestration and data platform design as we navigate the current era of data engineering.<br /><br /><br />Announcements<br /><ul><li>Hello and welcome to the Data Engineering Podcast, the show about modern data management</li><li>It’s 2024, why are we still doing data migrations by hand? Teams spend months—sometimes years—manually converting queries and validating data, burning resources and crushing morale. Datafold's AI-powered Migration Agent brings migrations into the modern era. Their unique combination of AI code translation and automated data validation has helped companies complete migrations up to 10 times faster than manual approaches. And they're so confident in their solution, they'll actually guarantee your timeline in writing. Ready to turn your year-long migration into weeks? Visit <a href="https://www.dataengineeringpodcast.com/datafold" target="_blank">dataengineeringpodcast.com/datafold</a> today to learn how Datafold can automate your migration and ensure source to target parity.&nbsp;</li><li>As a listener of the Data Engineering Podcast you clearly care about data and how it affects your organization and the world. For even more perspective on the ways that data impacts everything around us don't miss Data Citizens® Dialogues, the forward-thinking podcast brought to you by Collibra. You'll get further insights from industry leaders, innovators, and executives in the world's largest companies on the topics that are top of mind for everyone. In every episode of Data Citizens® Dialogues, industry leaders unpack data’s impact on the world, from big picture questions like AI governance and data sharing to more nuanced questions like, how do we balance offense and defense in data management? In particular I appreciate the ability to hear about the challenges that enterprise scale businesses are tackling in this fast-moving field. The Data Citizens Dialogues podcast is bringing the data conversation to you, so start listening now! Follow Data Citizens Dialogues on Apple, Spotify, YouTube, or wherever you get your podcasts.</li><li>Your host is Tobias Macey and today I'm interviewing Hugo Lu about the data platform and orchestration ecosystem and how to navigate the available options</li></ul>Interview<br /><ul><li>Introduction</li><li>How did you get involved in building data platforms?</li><li>Can you describe what an orchestrator is in the context of data platforms?<ul><li>There are many other contexts in which orchestration is necessary. What are some examples of how orchestrators have adapted (or failed to adapt) to the times?</li></ul></li><li>What are the core features that are necessary for an orchestrator to have when dealing with data-oriented workflows?</li><li>Beyond the bare necessities, what are some of the other features and design considerations that go into building a first-class dat platform or orchestration system?</li><li>There have been several generations of orchestration engines over the past several years. How would you characterize the different coarse groupings of orchestration engines across those generational boundaries?</li><li>How do the characteristics of a data orchestrator influence the overarching architecture of an organization's data platform/data operations?<ul><li>What about the reverse?</li></ul></li><li>How have the cycles of ML and AI workflow requirements impacted the design requirements for data orchestrators?</li><li>What are the most interesting, innovative, or unexpected ways that you have seen data orchestrators used?</li><li>What are the most interesting, unexpected, or challenging lessons that you have learned while working on data orchestration?</li><li>When is an orchestrator the wrong choice?</li><li>What are your predictions and/or hopes for the future of data orchestration?</li></ul>Contact Info<br /><ul><li><a href="https://medium.com/%40hugolu87" target="_blank">Medium</a></li><li><a href="https://www.linkedin.com/in/hugo-lu-confirmed/" target="_blank">LinkedIn</a></li></ul>Parting Question<br /><ul><li>From your perspective, what is the biggest thing data teams are missing in the technology today?</li></ul>Closing Announcements<br /><ul><li>Thank you for listening! Don't forget to check out our other shows. <a href="https://www.pythonpodcast.com" target="_blank">Podcast.__init__</a> covers the Python language, its community, and the innovative ways it is being used. The <a href="https://www.aiengineeringpodcast.com" target="_blank">AI Engineering Podcast</a> is your guide to the fast-moving world of building AI systems.</li><li>Visit the <a href="https://www.dataengineeringpodcast.com" target="_blank">site</a> to subscribe to the show, sign up for the mailing list, and read the show notes.</li><li>If you've learned something or tried out a project from the show then tell us about it! Email [email protected] with your story.</li></ul>Links<br /><ul><li><a href="https://www.getorchestra.io/" target="_blank">Orchestra</a></li><li><a href="https://markdowntohtml.com/https://www.dataengineeringpodcast.com/state-of-data-orchestration-episode-391" target="_blank">Previous Episode: Overview Of The State Of Data Orchestration</a></li><li><a href="https://en.wikipedia.org/wiki/Cron" target="_blank">Cron</a></li><li><a href="https://argo-cd.readthedocs.io/en/stable/" target="_blank">ArgoCD</a></li><li><a href="https://en.wikipedia.org/wiki/Directed_acyclic_graph" target="_blank">DAG</a></li><li><a href="https://kubernetes.io/" target="_blank">Kubernetes</a></li><li><a href="https://www.datamesh-architecture.com/" target="_blank">Data Mesh</a></li><li><a href="https://airflow.apache.org/" target="_blank">Airflow</a></li><li><a href="https://learn.microsoft.com/en-us/sql/integration-services/sql-server-integration-services?view=sql-server-ver16" target="_blank">SSIS == SQL Server Integration Services</a></li><li><a href="https://pentaho.com/" target="_blank">Pentaho</a></li><li><a href="https://pentaho.com/products/pentaho-data-integration/" target="_blank">Kettle</a></li><li><a href="https://datavolo.io/" target="_blank">DataVolo</a></li><li><a href="https://nifi.apache.org/" target="_blank">NiFi</a><ul><li><a href="https://www.dataengineeringpodcast.com/nifi-with-kevin-doran-and-andy-lopresto-episode-39" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://dagster.io/" target="_blank">Dagster</a></li><li><a href="https://grpc.io/" target="_blank">gRPC</a></li><li><a href="https://coalesce.io/" target="_blank">Coalesce</a><ul><li><a href="https://www.dataengineeringpodcast.com/coalesce-enterprise-analytics-transformations-episode-278" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://www.getdbt.com/" target="_blank">dbt</a></li><li><a href="https://datahubproject.io/" target="_blank">DataHub</a></li><li><a href="https://www.palantir.com/" target="_blank">Palantir</a></li></ul>The intro and outro music is from <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/Love_death_and_a_drunken_monkey/04_-_The_Hug" target="_blank">The Hug</a> by <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/" target="_blank">The Freak Fandango Orchestra</a> / <a href="http://creativecommons.org/licenses/by-sa/3.0/" target="_blank">CC BY-SA</a>
play-circle
59 MIN
An Exploration Of The Impediments To Reusable Data Pipelines
DEC 8, 2024
An Exploration Of The Impediments To Reusable Data Pipelines
Summary<br />In this episode of the Data Engineering Podcast the inimitable Max Beauchemin talks about reusability in data pipelines. The conversation explores the "write everything twice" problem, where similar pipelines are built without code reuse, and discusses the challenges of managing different SQL dialects and relational databases. Max also touches on the evolving role of data engineers, drawing parallels with front-end engineering, and suggests that generative AI could facilitate knowledge capture and distribution in data engineering. He encourages the community to share reference implementations and templates to foster collaboration and innovation, and expresses hopes for a future where code reuse becomes more prevalent.<br /><br /><br />Announcements<br /><ul><li>Hello and welcome to the Data Engineering Podcast, the show about modern data management</li><li>Data migrations are brutal. They drag on for months—sometimes years—burning through resources and crushing team morale. Datafold's AI-powered Migration Agent changes all that. Their unique combination of AI code translation and automated data validation has helped companies complete migrations up to 10 times faster than manual approaches. And they're so confident in their solution, they'll actually guarantee your timeline in writing. Ready to turn your year-long migration into weeks? Visit <a href="https://www.dataengineeringpodcast.com/datafold" target="_blank">dataengineeringpodcast.com/datafold</a> today for the details.</li><li>Your host is Tobias Macey and today I'm joined again by Max Beauchemin to talk about the challenges of reusability in data pipelines</li></ul>Interview<br /><ul><li>Introduction</li><li>How did you get involved in the area of data management?</li><li>Can you start by sharing your current thesis on the opportunities and shortcomings of code and component reusability in the data context?<ul><li>What are some ways that you think about what constitutes a "component" in this context?</li></ul></li><li>The data ecosystem has arguably grown more varied and nuanced in recent years. At the same time, the number and maturity of tools has grown. What is your view on the current trend in productivity for data teams and practitioners?</li><li>What do you see as the core impediments to building more reusable and general-purpose solutions in data engineering?<ul><li>How can we balance the actual needs of data consumers against their requests (whether well- or un-informed) to help increase our ability to better design our workflows for reuse?</li></ul></li><li>In data engineering there are two broad approaches; code-focused or SQL-focused pipelines. In principle one would think that code-focused environments would have better composability. What are you seeing as the realities in your personal experience and what you hear from other teams?</li><li>When it comes to SQL dialects, dbt offers the option of Jinja macros, whereas SDF and SQLMesh offer automatic translation. There are also tools like PRQL and Malloy that aim to abstract away the underlying SQL. What are the tradeoffs across those options that help or hinder the portability of transformation logic?</li><li>Which layers of the data stack/steps in the data journey do you see the greatest opportunity for improving the creation of more broadly usable abstractions/reusable elements?</li><li>low/no code systems for code reuse</li><li>impact of LLMs on reusability/composition</li><li>impact of background on industry practices (e.g. DBAs, sysadmins, analysts vs. SWE, etc.)</li><li>polymorphic data models (e.g. activity schema)</li><li>What are the most interesting, innovative, or unexpected ways that you have seen teams address composability and reusability of data components?</li><li>What are the most interesting, unexpected, or challenging lessons that you have learned while working on data-oriented tools and utilities?</li><li>What are your hopes and predictions for sharing of code and logic in the future of data engineering?</li></ul>Contact Info<br /><ul><li><a href="https://www.linkedin.com/in/maximebeauchemin/" target="_blank">LinkedIn</a></li></ul>Parting Question<br /><ul><li>From your perspective, what is the biggest gap in the tooling or technology for data management today?</li></ul>Closing Announcements<br /><ul><li>Thank you for listening! Don't forget to check out our other shows. <a href="https://www.pythonpodcast.com" target="_blank">Podcast.__init__</a> covers the Python language, its community, and the innovative ways it is being used. The <a href="https://www.aiengineeringpodcast.com" target="_blank">AI Engineering Podcast</a> is your guide to the fast-moving world of building AI systems.</li><li>Visit the <a href="https://www.dataengineeringpodcast.com" target="_blank">site</a> to subscribe to the show, sign up for the mailing list, and read the show notes.</li><li>If you've learned something or tried out a project from the show then tell us about it! Email [email protected] with your story.</li></ul>Links<br /><ul><li><a href="https://preset.io/blog/why-data-teams-keep-reinventing-the-wheel/" target="_blank">Max's Blog Post</a></li><li><a href="https://airflow.apache.org/" target="_blank">Airflow</a></li><li><a href="https://superset.apache.org/" target="_blank">Superset</a></li><li><a href="https://www.tableau.com/" target="_blank">Tableau</a></li><li><a href="https://cloud.google.com/looker/?hl=en" target="_blank">Looker</a></li><li><a href="https://www.microsoft.com/en-us/power-platform/products/power-bi" target="_blank">PowerBI</a></li><li><a href="https://en.wikipedia.org/wiki/Cohort_analysis" target="_blank">Cohort Analysis</a></li><li><a href="https://nextjs.org/" target="_blank">NextJS</a></li><li><a href="https://airbyte.com/" target="_blank">Airbyte</a><ul><li><a href="https://www.dataengineeringpodcast.com/airbyte-stable-release-episode-439" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://www.fivetran.com/" target="_blank">Fivetran</a><ul><li><a href="https://www.dataengineeringpodcast.com/fivetran-data-replication-episode-93/" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://segment.com/" target="_blank">Segment</a></li><li><a href="https://www.getdbt.com/" target="_blank">dbt</a></li><li><a href="https://sqlmesh.readthedocs.io/en/stable/" target="_blank">SQLMesh</a><ul><li><a href="https://www.dataengineeringpodcast.com/sqlmesh-open-source-dataops-episode-380" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://spark.apache.org/" target="_blank">Spark</a></li><li><a href="https://aws.amazon.com/what-is/lamp-stack/" target="_blank">LAMP Stack</a></li><li><a href="https://www.php.net/" target="_blank">PHP</a></li><li><a href="https://en.wikipedia.org/wiki/Relational_algebra" target="_blank">Relational Algebra</a></li><li><a href="https://en.wikipedia.org/wiki/Knowledge_graph" target="_blank">Knowledge Graph</a></li><li><a href="https://marshmallow.readthedocs.io/en/stable/" target="_blank">Python Marshmallow</a></li><li><a href="https://amzn.to/4f99suH" target="_blank">Data Warehouse Lifecycle Toolkit</a> (affiliate link)</li><li><a href="https://preset.io/blog/introducing-entity-centric-data-modeling-for-analytics/" target="_blank">Entity Centric Data Modeling</a> Blog Post</li><li><a href="https://amplitude.com/" target="_blank">Amplitude</a></li><li><a href="https://osacon.io/sessions/2024/ai-reality-checkpoint-the-good-the-bad-and-the-overhyped/" target="_blank">OSACon</a> presentation</li><li><a href="https://github.com/mitodl/ol-data-platform" target="_blank">ol-data-platform</a> Tobias' team's data platform code</li></ul>The intro and outro music is from <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/Love_death_and_a_drunken_monkey/04_-_The_Hug" target="_blank">The Hug</a> by <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/" target="_blank">The Freak Fandango Orchestra</a> / <a href="http://creativecommons.org/licenses/by-sa/3.0/" target="_blank">CC BY-SA</a>
play-circle
51 MIN
The Art of Database Selection and Evolution
DEC 1, 2024
The Art of Database Selection and Evolution
Summary<br />In this episode of the Data Engineering Podcast Sam Kleinman talks about the pivotal role of databases in software engineering. Sam shares his journey into the world of data and discusses the complexities of database selection, highlighting the trade-offs between different database architectures and how these choices affect system design, query performance, and the need for ETL processes. He emphasizes the importance of understanding specific requirements to choose the right database engine and warns against over-engineering solutions that can lead to increased complexity. Sam also touches on the tendency of engineers to move logic to the application layer due to skepticism about database longevity and advises teams to leverage database capabilities instead. Finally, he identifies a significant gap in data management tooling: the lack of easy-to-use testing tools for database interactions, highlighting the need for better testing paradigms to ensure reliability and reduce bugs in data-driven applications.<br /><br /><br />Announcements<br /><ul><li>Hello and welcome to the Data Engineering Podcast, the show about modern data management</li><li>It’s 2024, why are we still doing data migrations by hand? Teams spend months—sometimes years—manually converting queries and validating data, burning resources and crushing morale. Datafold's AI-powered Migration Agent brings migrations into the modern era. Their unique combination of AI code translation and automated data validation has helped companies complete migrations up to 10 times faster than manual approaches. And they're so confident in their solution, they'll actually guarantee your timeline in writing. Ready to turn your year-long migration into weeks? Visit <a href="https://www.dataengineeringpodcast.com/datafold" target="_blank">dataengineeringpodcast.com/datafold</a> today to learn how Datafold can automate your migration and ensure source to target parity.&nbsp;</li><li>Your host is Tobias Macey and today I'm interviewing Sam Kleinman about database tradeoffs across operating environments and axes of scale</li></ul>Interview<br /><ul><li>Introduction</li><li>How did you get involved in the area of data management?</li><li>The database engine you use has a substantial impact on how you architect your overall system. When starting a greenfield project, what do you see as the most important factor to consider when selecting a database?</li><li>points of friction introduced by database capabilities</li><li>embedded databases (e.g. SQLite, DuckDB, LanceDB), when to use and when do they become a bottleneck</li><li>single-node database engines (e.g. Postgres, MySQL), when are they legitimately a problem</li><li>distributed databases (e.g. CockroachDB, PlanetScale, MongoDB)</li><li>polyglot storage vs. general-purpose/multimodal databases</li><li>federated queries, benefits and limitations&nbsp;<ul><li>ease of integration vs. variability of performance and access control</li></ul></li></ul><br />Contact Info<br /><ul><li><a href="https://www.linkedin.com/in/samkleinman/" target="_blank">LinkedIn</a></li><li><a href="https://github.com/tychoish" target="_blank">GitHub</a></li></ul>Parting Question<br /><ul><li>From your perspective, what is the biggest gap in the tooling or technology for data management today?</li></ul>Closing Announcements<br /><ul><li>Thank you for listening! Don't forget to check out our other shows. <a href="https://www.pythonpodcast.com" target="_blank">Podcast.__init__</a> covers the Python language, its community, and the innovative ways it is being used. The <a href="https://www.aiengineeringpodcast.com" target="_blank">AI Engineering Podcast</a> is your guide to the fast-moving world of building AI systems.</li><li>Visit the <a href="https://www.dataengineeringpodcast.com" target="_blank">site</a> to subscribe to the show, sign up for the mailing list, and read the show notes.</li><li>If you've learned something or tried out a project from the show then tell us about it! Email [email protected] with your story.</li></ul>Links<br /><ul><li><a href="https://www.mongodb.com/" target="_blank">MongoDB</a></li><li><a href="https://neon.tech/" target="_blank">Neon</a><ul><li><a href="https://www.dataengineeringpodcast.com/neon-serverless-postgres-episode-433" target="_blank">Podcast Episode</a></li></ul></li><li><a href="https://glaredb.com/" target="_blank">GlareDB</a></li><li><a href="https://en.wikipedia.org/wiki/NoSQL" target="_blank">NoSQL</a></li><li><a href="https://aws.amazon.com/about-aws/whats-new/2024/08/amazon-s3-conditional-writes/" target="_blank">S3 Conditional Write</a></li><li><a href="https://en.wikipedia.org/wiki/Event-driven_architecture" target="_blank">Event driven architecture</a></li><li><a href="https://www.cockroachlabs.com/" target="_blank">CockroachDB</a></li><li><a href="https://www.couchbase.com/" target="_blank">Couchbase</a></li><li><a href="https://cassandra.apache.org/_/index.html" target="_blank">Cassandra</a></li></ul>The intro and outro music is from <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/Love_death_and_a_drunken_monkey/04_-_The_Hug" target="_blank">The Hug</a> by <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/" target="_blank">The Freak Fandango Orchestra</a> / <a href="http://creativecommons.org/licenses/by-sa/3.0/" target="_blank">CC BY-SA</a>
play-circle
59 MIN
Bridging Code and UI in Data Orchestration with Kestra
NOV 26, 2024
Bridging Code and UI in Data Orchestration with Kestra
Summary<br />In this episode of the Data Engineering Podcast, Anna Geller talks about the integration of code and UI-driven interfaces for data orchestration. Anna defines data orchestration as automating the coordination of workflow nodes that interact with data across various business functions, discussing how it goes beyond ETL and analytics to enable real-time data processing across different internal systems. She explores the challenges of using existing scheduling tools for data-specific workflows, highlighting limitations and anti-patterns, and discusses Kestra's solution, a low-code orchestration platform that combines code-driven flexibility with UI-driven simplicity. Anna delves into Kestra's architectural design, API-first approach, and pluggable infrastructure, and shares insights on balancing UI and code-driven workflows, the challenges of open-core business models, and innovative user applications of Kestra's platform.<br /><br /><br />Announcements<br /><ul><li>Hello and welcome to the Data Engineering Podcast, the show about modern data management</li><li>Data migrations are brutal. They drag on for months—sometimes years—burning through resources and crushing team morale. Datafold's AI-powered Migration Agent changes all that. Their unique combination of AI code translation and automated data validation has helped companies complete migrations up to 10 times faster than manual approaches. And they're so confident in their solution, they'll actually guarantee your timeline in writing. Ready to turn your year-long migration into weeks? Visit <a href="https://www.dataengineeringpodcast.com/datafold" target="_blank">dataengineeringpodcast.com/datafold</a> today for the details.</li><li>As a listener of the Data Engineering Podcast you clearly care about data and how it affects your organization and the world. For even more perspective on the ways that data impacts everything around us you should listen to Data Citizens® Dialogues, the forward-thinking podcast from the folks at Collibra. You'll get further insights from industry leaders, innovators, and executives in the world's largest companies on the topics that are top of mind for everyone. They address questions around AI governance, data sharing, and working at global scale. In particular I appreciate the ability to hear about the challenges that enterprise scale businesses are tackling in this fast-moving field. While data is shaping our world, Data Citizens Dialogues is shaping the conversation. Subscribe to Data Citizens Dialogues on Apple, Spotify, Youtube, or wherever you get your podcasts.</li><li>Your host is Tobias Macey and today I'm interviewing Anna Geller about incorporating both code and UI driven interfaces for data orchestration</li></ul>Interview<br /><ul><li>Introduction</li><li>How did you get involved in the area of data management?</li><li>Can you start by sharing a definition of what constitutes "data orchestration"?</li><li>There are many orchestration and scheduling systems that exist in other contexts (e.g. CI/CD systems, Kubernetes, etc.). Those are often adapted to data workflows because they already exist in the organizational context. What are the anti-patterns and limitations that approach introduces in data workflows?<ul><li>What are the problems that exist in the opposite direction of using data orchestrators for CI/CD, etc.?</li></ul></li><li>Data orchestrators have been around for decades, with many different generations and opinions about how and by whom they are used. What do you see as the main motivation for UI vs. code-driven workflows?</li><li>What are the benefits of combining code-driven and UI-driven capabilities in a single orchestrator?<ul><li>What constraints does it necessitate to allow for interoperability between those modalities?</li></ul></li><li>Data Orchestrators need to integrate with many external systems. How does Kestra approach building integrations and ensure governance for all their underlying configurations?</li><li>Managing workflows at scale across teams can be challenging in terms of providing structure and visibility of dependencies across workflows and teams. What features does Kestra offer so that all pipelines and teams stay organised?</li><li>What are the most interesting, innovative, or unexpected ways that you have seen Kestra used?</li><li>What are the most interesting, unexpected, or challenging lessons that you have learned while working on Kestra?</li><li>When is Kestra the wrong choice?</li><li>What do you have planned for the future of Kestra?</li></ul>Contact Info<br /><ul><li><a href="https://www.linkedin.com/in/anna-geller-12a86811a/" target="_blank">LinkedIn</a></li><li><a href="https://annageller.medium.com/" target="_blank">Blog</a></li></ul>Parting Question<br /><ul><li>From your perspective, what is the biggest gap in the tooling or technology for data management today?</li></ul>Closing Announcements<br /><ul><li>Thank you for listening! Don't forget to check out our other shows. <a href="https://www.pythonpodcast.com" target="_blank">Podcast.__init__</a> covers the Python language, its community, and the innovative ways it is being used. The <a href="https://www.aiengineeringpodcast.com" target="_blank">AI Engineering Podcast</a> is your guide to the fast-moving world of building AI systems.</li><li>Visit the <a href="https://www.dataengineeringpodcast.com" target="_blank">site</a> to subscribe to the show, sign up for the mailing list, and read the show notes.</li><li>If you've learned something or tried out a project from the show then tell us about it! Email [email protected] with your story.</li></ul>Links<br /><ul><li><a href="https://kestra.io/" target="_blank">Kestra</a></li><li><a href="https://en.wikipedia.org/wiki/CI/CD" target="_blank">CI/CD</a></li><li><a href="https://en.wikipedia.org/wiki/Finite-state_machine" target="_blank">State Machine</a></li><li><a href="https://aws.amazon.com/lambda/" target="_blank">AWS Lambda</a></li><li><a href="https://github.com/features/actions" target="_blank">GitHub Actions</a></li><li><a href="https://aws.amazon.com/fargate/" target="_blank">ECS Fargate</a></li><li><a href="https://airflow.apache.org/" target="_blank">Airflow</a></li><li><a href="https://kafka.apache.org/" target="_blank">Kafka</a></li><li><a href="https://www.elastic.co/" target="_blank">Elasticsearch</a></li><li><a href="https://airflow.apache.org/docs/apache-airflow/stable/core-concepts/xcoms.html" target="_blank">Airflow XCom</a></li></ul>The intro and outro music is from <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/Love_death_and_a_drunken_monkey/04_-_The_Hug" target="_blank">The Hug</a> by <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/" target="_blank">The Freak Fandango Orchestra</a> / <a href="http://creativecommons.org/licenses/by-sa/3.0/" target="_blank">CC BY-SA</a><br /><br />In this episode of the Data Engineering Podcast, host Tobias Macy interviews Anna Geller, a data engineer turned product manager, about the integration of code and UI-driven interfaces for data orchestration. Anna shares her journey from working with data during an internship at KPMG to her current role as a product lead at Kestra. She provides her insights into the concept of data orchestration, emphasizing its broader scope beyond just ETL and analytics, and discusses the challenges and anti-patterns that arise when using existing scheduling systems for data-specific workflows.<br /><br />Anna explains the overlap between CI/CD, scheduling, and orchestration tools, and the limitations that occur when these tools are used for data workflows. She highlights the importance of visibility and governance at scale and the need for a dedicated orchestrator like Kestra. The conversation also delves into the challenges of using data orchestrators for non-data workflows and the benefits of combining code and UI-driven approaches.<br /><br />Anna discusses Kestra's architecture, which supports both JDBC and Kafka backends, and its focus on API-first interactions. She explains how Kestra handles task granularity, inputs, and outputs, and the flexibility provided by its plugin system. The episode also explores Kestra's approach to data as assets, the target audience for Kestra, and how it bridges different workflows across organizational boundaries.<br /><br />The discussion touches on Kestra's open-core model, the challenges of balancing open-source and enterprise features, and the innovative ways Kestra is being applied. Anna shares insights into Kestra's local development experience, the lessons learned in building the product, and the upcoming features and projects that Kestra is excited to explore.
play-circle
44 MIN
Streaming Data Into The Lakehouse With Iceberg And Trino At Going
NOV 18, 2024
Streaming Data Into The Lakehouse With Iceberg And Trino At Going
<p>In this episode, I had the pleasure of speaking with Ken Pickering, VP of Engineering at Going, about the intricacies of streaming data into a Trino and Iceberg lakehouse. Ken shared his journey from product engineering to becoming deeply involved in data-centric roles, highlighting his experiences in ecommerce and InsurTech. At Going, Ken leads the data platform team, focusing on finding travel deals for consumers, a task that involves handling massive volumes of flight data and event stream information.<br /><br />Ken explained the dual approach of passive and active search strategies used by Going to manage the vast data landscape. Passive search involves aggregating data from global distribution systems, while active search is more transactional, querying specific flight prices. This approach helps Going sift through approximately 50 petabytes of data annually to identify the best travel deals.<br /><br />We delved into the technical architecture supporting these operations, including the use of Confluent for data streaming, Starburst Galaxy for transformation, and Databricks for modeling. Ken emphasized the importance of an open lakehouse architecture, which allows for flexibility and scalability as the business grows.<br /><br />Ken also discussed the composition of Going's engineering and data teams, highlighting the collaborative nature of their work and the reliance on vendor tooling to streamline operations. He shared insights into the challenges and strategies of managing data life cycles, ensuring data quality, and maintaining uptime for consumer-facing applications.<br /><br />Throughout our conversation, Ken provided a glimpse into the future of Going's data architecture, including potential expansions into other travel modes and the integration of large language models for enhanced customer interaction. This episode offers a comprehensive look at the complexities and innovations in building a data-driven travel advisory service.</p>
play-circle
39 MIN