有没有办法将我的spark数据帧的每一行写为dynamoDB表中的新项？(中pySpark)
我在boto3库中使用了这个代码,但我想知道是否有另一种方法,避免使用pandas和执行for loop步骤:
sparkDF_dict = sparkDF.toPandas().to_dict('records')
for item in sparkDF_dict :
table.put_item(Item = item)