cancel
Showing results for 
Search instead for 
Did you mean: 
Data Engineering
cancel
Showing results for 
Search instead for 
Did you mean: 

How do I process each new record when using autoloader.

Gabriel0007
New Contributor III

For instance, I'm ingesting webhook data into a delta table with autoloader and need to run a process for each new record as it arrives.

2 REPLIES 2

AmanSehgal
Honored Contributor III

With autoloader, you can do something like changelog and record data about operations performed on each micro batch - like affected id, I/U/D, timestamp etc..

Then you can make use of this changelog table, and run subsequent processes for each row affected per micro batch..

Thank you for the info. I'm just starting out with Databricks.

Welcome to Databricks Community: Lets learn, network and celebrate together

Join our fast-growing data practitioner and expert community of 80K+ members, ready to discover, help and collaborate together while making meaningful connections. 

Click here to register and join today! 

Engage in exciting technical discussions, join a group with your peers and meet our Featured Members.