Databricks ( Spark ) にてデータフレームのカラム名を一括で変更する方法 - Qiita

def rename_df_cols( df, cols_names, ): counter = 0 for new_col in cols_names: counter_str = str(counter) old_col_name = df.columns[counter] df = df.withColumnRenamed(old_col_name, new_col) counter += 1 return df import inspect from pyspark.sql import DataFrame, SparkSession from pyspark.dbutils import DBUtils def put_files_to_storage( path, content, is_overwrite = True, ): # 最初の行と最後の行を削除 content =