cancel
Showing results forย 
Search instead forย 
Did you mean:ย 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Showing results forย 
Search instead forย 
Did you mean:ย 

Azure CosmosDB change feed ingestion via DLT

Ogi
New Contributor II

Is there a way to ingest Azure CosmosDB data via Delta Live Tables? If I use regular workflows it works well, but with DLT I'm not able to set CosmosDB Connector on a cluster.

1 ACCEPTED SOLUTION

Accepted Solutions

Hubert-Dudek
Esteemed Contributor III

In DLT, you can install libraries only through pip. The problem is that the CosmosDB driver is installed through Maven / JAR. I don't think it is preinstalled.

Maybe you can send the change data feed to Event Hub and read Event Hub in DLT as Kafka.

https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/changefeed-ecommerce-solution

View solution in original post

3 REPLIES 3

Hubert-Dudek
Esteemed Contributor III

In DLT, you can install libraries only through pip. The problem is that the CosmosDB driver is installed through Maven / JAR. I don't think it is preinstalled.

Maybe you can send the change data feed to Event Hub and read Event Hub in DLT as Kafka.

https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/changefeed-ecommerce-solution

Jfoxyyc
Valued Contributor

I would likely do the same, but instead send the change data feed to Event Hub and materialize in abfss as json or parquet or some format and consume via DLT using autoloader.

Ogi
New Contributor II

Thanks a lot! Just wanted to doublecheck whether this natively exists.

Connect with Databricks Users in Your Area

Join a Regional User Group to connect with local Databricks users. Events will be happening in your city, and you wonโ€™t want to miss the chance to attend and share knowledge.

If there isnโ€™t a group near you, start one and help create a community that brings people together.

Request a New Group