你好,
我想更新三角洲表中的數據。同樣的合並選項來到我的注意。
然而我的下麵的代碼最終錯誤如圖所示。請建議我失蹤。謝謝你!
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
從三角洲。表導入*
熊貓作為pd導入
dfsource = pd。DataFrame({“磚”:{0:“abc”},
“run_datetime”: {0: ' 2022-12-05 16:33:22.324 '}
})
tabletoupdate = DeltaTable。forName(火花,“eda_rw.eda_log_bridge_run”)
tabletoupdate.alias \(“目標”)
.merge (
dfsource,
的目標。BRI = dfsource.BRI '
“target.run_datetime = dfsource.run_datetime”
)\
.whenMatchedUpdate(設置=
{
“展望”:“dfsource.BRI”,
:“run_datetime dfsource.run_datetime”
}
)\
.whenNotMatchedInsert(值=
{
“展望”:“dfsource.BRI”,
:“run_datetime dfsource.run_datetime”
}
)\
. execute ()
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
Viren