The Cosmos DB source connector is a Change Data Capture connector that leverages Cosmos DB's change feed. This connector will perform an initial snapshot of the data. Then, it will stream every
UPDATE operation and push the events into a Meroxa stream. Currently, the Cosmos change feed doesn't log
Before creating a source connector:
- Setup - Setup your Cosmos DB instance and acquire the credentials needed to talk to Meroxa.
- Add Resource - Add a Cosmos DB resource to your Meroxa Resource.
The input for the connector is an Azure Cosmos Collection Id.
Then, to configure Cosmos DB as a source:
Using the Dashboard, perform these steps to add a new source to a pipeline:
- Create a new pipeline.
- Add a source connector:
- Name your new connector and select your Cosmos DB resource:
- Select "Create" and Done 🚀.
First, you must create a new pipeline.
Then, using the CLI, you can run the following command to add a new source to a pipeline:
meroxa connector create to-cosmosdb-connector \
--from my-cosmosdb \
--input my-container-name \
The command above creates a new source connector called
to-cosmosdb-connector, sets the source to a resource named
my-cosmosdb, and configures the input.