我試圖從Azure磚dataframe加載數據到宇宙db容器使用下麵的命令
cfg = {
“spark.cosmos。accountEndpoint”: cosmosEndpoint,
“spark.cosmos。accountKey”: cosmosMasterKey,
“spark.cosmos。數據庫”:cosmosDatabaseName,
“spark.cosmos。容器”:cosmosContainerName,
}
df.write.format (cosmos.oltp) .options (* * cfg) .mode(“追加”).save ()
我查詢是宇宙如果目標容器已經與源數據匹配一個特定id會試圖覆蓋id細節還是會更新現有的id細節添加新項目或將隻添加/追加新的id和聯係現有的嗎?
插入是什麼類型和我們可以使用append模式?
背景:我試圖加載為零售客戶交易細節通過手動運行附加等不同的時間間隔從2012年到2017年,然後2017到2022。同樣的客戶會使交易的時間所以這append模式將如何處理?
