How to handle cdc changes(updates.dein data vault model

Help
, , ,
1

Hi Team,

I am working on DBT , we have requirement where I need to handle batch and CDC(change data capture) changes.

In this case input json messages are different in case of batch and CDC. So I need to write parsing logic differently for batch and CDC based on change type received from source.

Example:
If change type = ‘CREATE’

   Call batch dbt models(7 models in my case)

Else
If change type = ‘UPDATE’

  Call incremental batch models(7 models in my case)

End if.

How to do we handle this flow in DBT?

Thanks!