DP-420: Designing and Implementing Cloud-Native Applications Using Microsoft Azure Cosmos DBDemo

Question

You have an Azure Cosmos DB for NoSQL account that contains a container named Customers.

You need to add customers to Customers by using the Azure Cosmos DB Spark Connector.

How should you complete the code?

Select

newCustomers = spark.createDataFrame((\
    (“ABC001”, “ABC Corporation”, 0, True),\
    (“BEL001”, “BEL Corporation”, 20000, False)))\
    .toDF(“id”, “companyName”, “creditLimit”, “isOnCreditHold”)
newCustomers.write\
    .format \
    .options(**cfg)\
    .mode \
    .save()

Explanation

Azure Cosmos DB's Spark connector uses the cosmos.oltp data source format for transactional writes to Azure Cosmos DB for NoSQL. Spark APPEND mode adds the new DataFrame rows/documents to the destination without replacing its existing contents.

Learn more

Azure Cosmos DB Spark connector - Write data

DP-420: Designing and Implementing Cloud-Native Applications Using Microsoft Azure Cosmos DBDemo

AstroTutor

Notes

Readiness

QuestionQ156

Community Discussion