[Python] Update target column with optional source columns

Discussão em 'Python' iniciado por Stack, Fevereiro 20, 2025.

  1. Stack

    Stack Membro Participativo

    I am trying to load on prem transaction log table and update a databricks table.In Source table,the column reqdetails table hold all the information and expect ProductID remaining columns are dynamic(not all columns exists in the request) all time the optional/nullable.Could you please let me the process using python in databricks ? Explored StructType but it needs mandatory specific columns.

    Source Table

    Req ID Type Req Details Status
    1 Update ProductID=234;ProductName=LawnMover;Price=58 True
    2 Update ProductID=874;Price=478 True
    3 Update ProductID=678;ProductParentgroup=Watersuppuly;Price=1.6 True


    Target table before Update

    ProductID ProductParentgroup ProductName Price
    234 Utility Mover 86
    874 HOA Sink 450
    678 Water Filters 1.2

    Target table after Update

    ProductID ProductParentgroup ProductName Price
    234 Utility LawnMover 58
    874 HOA Sink 478
    678 Watersupply Filters 1.6

    Continue reading...

Compartilhe esta Página