Designing, developing, maintaining, and optimizing ETL (Extract, Transform, Load) processes in Databricks for data warehousing, data lakes, and analytics.
Working closely with data architects and business teams to ensure efficient transformation and movement of data to meet business needs, including handling Change Data Capture (CDC) and streaming data.
Reviewing business requirements, understanding business rules and the transactional data model.
Defining conceptual, logical, and physical models mapping from data source to curated model and data mart.
Analyzing requirements and recommending changes to the physical model.
Developing scripts for the physical model, creating database and/or Delta Lake file structure.
Accessing Oracle DB environments and setting necessary tools for developing solutions.
Implementing data design methodologies, historical and dimensional models.
Performing data profiling, assessing data accuracy, and designing data quality and master data management rules.
Conducting Functionality Review, Data Load review, Performance Review, and Data Consistency checks.
Assisting in troubleshooting data mart design issues.
Reviewing ETL performance with developers and suggesting improvements.
Participating in end-to-end integrated testing for Full Load and Incremental Load and advising on issues.
Tools Used:
Azure Data bricks, Delta Lake, Delta Live Tables, and Spark to process structured and unstructured data.
Azure Databricks/PySpark (good Python/PySpark knowledge required) to build transformations of raw data into curated zone in the data lake.
Azure Databricks/PySpark/SQL (good SQL knowledge required) to develop and/or troubleshoot transformations of curated data into FHIR.
Understand requirements and recommend changes to models to support ETL design.
Define primary keys, indexing strategies, and relationships to enhance data integrity and performance.
Define initial schemas for each data layer.
Assist with data modeling and updates to source-to-target mapping documentation.
Document and implement schema validation rules to ensure incoming data conforms to expected formats and standards.
Design data quality checks within the pipeline to catch inconsistencies, missing values, or errors early in the process.
Communicate with business and IT experts on changes required to conceptual, logical, and physical models.
Develop ETL strategy and solution for different data modules.
Understand tables and relationships in the data model.
Create low-level design documents and test cases for ETL development.
Implement error-catching, logging, retry mechanisms, and handling data anomalies.
Create workflows and pipeline design.
Develop and test data pipelines with Incremental and Full Load.
Develop high-quality ETL mappings, scripts, and notebooks.
Maintain pipeline from Oracle data source to Azure Delta Lakes and FHIR.
Perform unit testing.
Ensure performance monitoring and improvement.
Review ETL performance and troubleshoot performance issues.
Log activity for each pipeline and transformation.
Optimize ETL performance.
Conduct end-to-end integrated testing for Full Load and Incremental Load.
Plan for Go Live, Production Deployment.
Create production deployment steps.
Configure parameters and scripts for go-live testing and review.
Create release documents and help build and deploy code across servers.
Provide Go Live Support and post-deployment reviews.
Review existing ETL process, tools, and recommend performance improvements.
Review infrastructure and remediate issues for process improvement.
Knowledge Transfer to Ministry staff, including developing documentation and sharing ETL end-to-end design, troubleshooting steps, configuration, and scripts.
Experience:
7+ years working experience with SQL Server, T-SQL, Oracle, PL/SQL development or similar relational databases.
2+ years working experience with Azure Data Factory, Databricks, and Python development.
Experience building data ingestion and change data capture using Oracle Golden Gate.
Experience in designing, developing, and implementing ETL pipelines using Databricks and related tools to ingest, transform, and store large-scale datasets.
Experience in leveraging Databricks, Delta Lake, Delta Live Tables, and Spark to process structured and unstructured data.
Experience working with data warehouses, delta, and full loads.
Experience in data modeling and tools (e.g., SAP Power Designer, Visio or similar).
Experience developing in an Agile environment.
Experience with SQL Server SSIS or other ETL tools.
Solid knowledge and experience with SQL scripting.
Experience developing, testing, and documenting ETL pipelines.
Experience analyzing, designing, and implementing data validation techniques.
Ability to utilize SQL to perform DDL tasks and complex queries.
Good knowledge of database performance optimization techniques.
Ability to assist in the requirements analysis and subsequent developments and conduct unit testing and assist in test preparations to ensure data integrity.
Work closely with Designers, Business Analysts and other Developers; Liaise with Project Managers, Quality Assurance Analysts and Business Intelligence Consultants.
Design and implement technical enhancements of Data Warehouse as required.
Technical Skills (70 points):
Experience in developing and managing ETL pipelines, jobs, and workflows in Databricks.
Deep understanding of Delta Lake for building data lakes and managing ACID transactions, schema evolution, and data versioning.
Experience automating ETL pipelines using Delta Live Tables, including handling Change Data Capture (CDC) for incremental data loads.
Proficient in structuring data pipelines with the Medallion Architecture to scale data pipelines and ensure data quality.
Hands-on experience developing streaming tables in Databricks using Structured Streaming and readStream to handle real-time data.
Expertise in integrating CDC tools like GoldenGate or Debezium for processing incremental updates and managing real-time data ingestion.
Experience using Unity Catalog to manage data governance, access control, and ensure compliance.
Skilled in managing clusters, jobs, autoscaling, monitoring, and performance optimization in Databricks environments.
Knowledge of using Databricks Autoloader for efficient batch and real-time data ingestion.
Experience with data governance best practices, including implementing security policies, access control, and auditing with Unity Catalog.
Proficient in creating and managing Databricks Workflows to orchestrate job dependencies and schedule tasks.
Strong knowledge of Python, PySpark, and SQL for data manipulation and transformation.
Experience integrating Databricks with cloud storage solutions such as Azure Blob Storage, AWS S3, or Google Cloud Storage.
Familiarity with external orchestration tools like Azure Data Factory.
Implementing logical and physical data models.
Knowledge of FHIR is an asset.
Design Documentation and Analysis Skills (20 points):
Demonstrated experience in creating design documentation such as: Schema definitions, Error handling and logging, ETL Process Documentation, Job Scheduling and Dependency Management, Data Quality and Validation Checks, Performance Optimization and Scalability Plans, Troubleshooting Guides, Data Lineage and Security and Access Control Policies applied within ETL.
Experience in Fit-Gap analysis, system use case reviews, requirements reviews, coding exercises and reviews.
Participate in defect fixing, testing support and development activities for ETL.
Analyze and document solution complexity and interdependencies including providing support for data validation.
Strong analytical skills for troubleshooting, problem-solving, and ensuring data quality.
Communication and Leadership Skills (10 points):
Ability to collaborate effectively with cross-functional teams, provide technical guidance, support to other team members on Databricks best practices and communicate complex technical concepts to non-technical stakeholders.
Strong problem-solving skills and experience working in an Agile or Scrum environment.
Must have previous work experience in conducting Knowledge Transfer sessions, ensuring the resources will receive the required knowledge to support the system.
Must develop documentation and materials as part of a review and knowledge transfer to other members.