pazabalm / spark_python Goto Github PK

Cambiar columna "Versión" a "Version"

spark.read.table("tabla").withColumnRenamed("Versión","Version").write.format("delta").mode("overwrite").option("overwriteSchema", "true").saveAsTable("tabla")

#dbutils.fs.rm("dbfs:/FileStore/shared_uploads/usuario/directorio/archivo.xlsm")

#dbutils.fs.rm("dbfs:/FileStore/shared_uploads/usuario/, True)
#dbutils.fs.mkdirs("dbfs:/FileStore/shared_uploads/usuariodirectorio")

import os
usuario="[email protected]"

all_files = dbutils.fs.ls("dbfs:/FileStore/shared_uploads/"+usuario)
files = []
for file in all_files:
split_tup = os.path.splitext(file.name)

file_name = split_tup[0]
file_extension = split_tup[1]

if (file_extension==".xls" or file_extension==".xlsx" or file_extension==".TXT" or file_extension==".csv" or file_extension==".xlsm"):
print (file_name+file_extension)
dbutils.fs.rm("dbfs:/FileStore/shared_uploads/"+usuario+"/"+file_name+file_extension)

dbutils.fs.ls("dbfs:/FileStore/shared_uploads/"+usuario)